Skip to content

Commit f474569

Browse files
committed
fix: widen metadata manager waits
1 parent c3db753 commit f474569

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ public void should_refresh_single_node() {
198198
// Then
199199
// the info should have been copied to the node
200200
assertThatStage(refreshNodeFuture).isSuccess();
201-
verify(info, timeout(2000)).getDatacenter();
201+
verify(info, timeout(5000)).getDatacenter();
202202
assertThat(node.getDatacenter()).isEqualTo("dc1");
203203
}
204204

@@ -476,7 +476,7 @@ public void should_fire_added_event_on_registerNode_after_initial_refresh() {
476476
// Then — NodeStateEvent.added should have been fired
477477
assertThatStage(result).isSuccess();
478478
Node registeredNode = result.toCompletableFuture().join();
479-
verify(eventBus, timeout(2000)).fire(NodeStateEvent.added((DefaultNode) registeredNode));
479+
verify(eventBus, timeout(5000)).fire(NodeStateEvent.added((DefaultNode) registeredNode));
480480
}
481481

482482
@Test
@@ -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(2, TimeUnit.SECONDS).until(condition);
531+
await().atMost(5, TimeUnit.SECONDS).until(condition);
532532
}
533533
}

0 commit comments

Comments
 (0)