Fix unit test

Signed-off-by: Dinu John <[email protected]>
dinujoh · May 20, 2024 · e272e88 · e272e88
1 parent d24c880
commit e272e88
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...db/src/test/java/org/opensearch/dataprepper/plugins/mongo/export/ExportSchedulerTest.java b/...db/src/test/java/org/opensearch/dataprepper/plugins/mongo/export/ExportSchedulerTest.java
@@ -165,7 +165,7 @@ void test_export_run() {
         ExecutorService executorService = Executors.newSingleThreadExecutor();
         final Future<?> future = executorService.submit(() -> exportScheduler.run());
         await()
-            .atMost(Duration.ofMillis(DEFAULT_GET_PARTITION_BACKOFF_MILLIS).plus(Duration.ofSeconds(60)))
+            .atMost(Duration.ofMillis(DEFAULT_GET_PARTITION_BACKOFF_MILLIS).plus(Duration.ofSeconds(2)))
             .untilAsserted(() -> verify(coordinator, times(1)).createPartition(any()));
 
         future.cancel(true);