test: increment time continously

In order to prevent for flakiness the time needs to be increased everytime so we can retrigger the position distribution.
camunda · Jan 3, 2022 · fc0f9c6 · fc0f9c6
1 parent 1f6bd9b
commit fc0f9c6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...c/test/java/io/camunda/zeebe/broker/exporter/stream/ExporterDirectorDistributionTest.java b/...c/test/java/io/camunda/zeebe/broker/exporter/stream/ExporterDirectorDistributionTest.java
@@ -106,6 +106,8 @@ public void shouldDistributeExporterPositions() {
 
     // then
     Awaitility.await("Active Director has distributed positions and passive has received it")
+        .conditionEvaluationListener(
+            condition -> activeExporters.getClock().addTime(DISTRIBUTION_INTERVAL))
         .untilAsserted(
             () -> {
               assertThat(passiveExporterState.getPosition(EXPORTER_ID_1)).isEqualTo(position);
@@ -133,6 +135,8 @@ public void shouldNotResetExporterPositionWhenOldPositionReceived() {
 
     final var passiveExporterState = passiveExporters.getExportersState();
     Awaitility.await("Active Director has distributed positions and passive has received it")
+        .conditionEvaluationListener(
+            condition -> activeExporters.getClock().addTime(DISTRIBUTION_INTERVAL))
         .untilAsserted(
             () -> {
               assertThat(passiveExporterState.getPosition(EXPORTER_ID_1)).isEqualTo(position);