Skip to content

Commit b5f915b

Browse files
committed
fix: extend flaky CI waits
1 parent 2366b0b commit b5f915b

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

core/src/test/java/com/datastax/oss/driver/internal/core/metadata/MetadataManagerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,6 +528,6 @@ public void removeNode(InetSocketAddress broadcastRpcAddress) {
528528

529529
// Wait for all the tasks on the pool's admin executor to complete.
530530
private void waitForPendingAdminTasks(Callable<Boolean> condition) {
531-
await().atMost(5, TimeUnit.SECONDS).until(condition);
531+
await().atMost(10, TimeUnit.SECONDS).until(condition);
532532
}
533533
}

integration-tests/src/test/java/com/datastax/oss/driver/core/cql/PreparedStatementCachingIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,8 +269,9 @@ private void invalidationTestInner(
269269
assertThat(Uninterruptibles.awaitUninterruptibly(typeChangeEventLatch, 60, TimeUnit.SECONDS))
270270
.withFailMessage("typeChangeEventLatch did not trigger before timeout")
271271
.isTrue();
272+
// Scylla schema propagation can lag long enough in CI that the removal callback arrives late.
272273
await()
273-
.atMost(120, TimeUnit.SECONDS)
274+
.atMost(4, TimeUnit.MINUTES)
274275
.untilAsserted(
275276
() -> {
276277
assertThat(removedQueryIds.get()).isNotEmpty().get().isEqualTo(queryId2);

0 commit comments

Comments
 (0)