trigger-phrase: '.*run\W+elasticsearch-ci/packaging-tests-windows-sample.*'
          github-hooks: true
          status-context: elasticsearch-ci/packaging-tests-windows-sample
          cancel-builds-on-update: true
          # We've removed the no-jdk distribution on master as well
          black-list-target-branches:
            - master
            - 6.8
          excluded-regions:
            - ^docs/.*

    client.dispatcher.executorService.shutdownNow()

    val exception = callFailure.get(5, TimeUnit.SECONDS)
    assertThat(exception.message)
      .isNotNull()
      .startsWith("canceled due to")
    assertThat(exception).isInstanceOf<IOException>()
    assertThat(exception.cause)
      .isNotNull()
      .matchesPredicate { it is InterruptedException || it is RejectedExecutionException }

	if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok {
		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
	}

	ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
	defer cancel()
	txCtx := tx.WithContext(ctx)

	user := *GetUser("prepared_stmt", Config{})

	txCtx.Create(&user)

	var result1 User

   * UnsupportedOperationException.
   *
   * <p>The implementation deviates from the {@code ExecutorService} specification with regards to
   * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is
   * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing
   * tasks. Second, the returned list will always be empty, as any submitted task is considered to

labels.crawling_info_created_time=Criado
labels.crawling_info_delete_all_link=Excluir tudo
labels.crawling_info_delete_all_confirmation=Tem certeza de que deseja excluir tudo?
labels.crawling_info_delete_all_cancel=Cancelar
labels.crawling_info_thread_dump=Despejo de threads
labels.crawling_info_CrawlerStartTime=Hora de início do rastreador
labels.crawling_info_CrawlerEndTime=Hora de término do rastreador

      valueAndCloser.closeAsync();
    }
    super.waitUntilClosed(closingFuture);
  }

  @Override
  void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
    assertThat(closingFuture.cancel(false)).isTrue();
    ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
    waitUntilClosed(closingFuture);
    futureCancelled.countDown();
  }

    } finally {
      Thread.interrupted();
    }
  }

  public void testGetUnchecked_cancelled() {
    SettableFuture<String> future = SettableFuture.create();
    future.cancel(true);
    assertThrows(CancellationException.class, () -> getUnchecked(future));
  }

  public void testGetUnchecked_executionExceptionChecked() {
    UncheckedExecutionException expected =
        assertThrows(

    } finally {
      Thread.interrupted();
    }
  }

  public void testGetUnchecked_cancelled() {
    SettableFuture<String> future = SettableFuture.create();
    future.cancel(true);
    assertThrows(CancellationException.class, () -> getUnchecked(future));
  }

  public void testGetUnchecked_executionExceptionChecked() {
    UncheckedExecutionException expected =
        assertThrows(

    future = service.schedule(() -> {}, 5, MINUTES);
    future.cancel(true);
    assertTrue(future.isCancelled());
    delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
    assertTrue(delegateFuture.isCancelled());

    delegateQueue.clear();

    future = service.scheduleAtFixedRate(() -> {}, 5, 5, MINUTES);
    future.cancel(true);
    assertTrue(future.isCancelled());

            bool,
            Doc(
                """
                By default, if no HTTP Authorization header is provided, required for
                OAuth2 authentication, it will automatically cancel the request and
                send the client an error.

                If `auto_error` is set to `False`, when the HTTP Authorization header