fix: wait for processing start when increasing time

When we increase the time it takes some time before the engine has started processing again, and before it is writing new records to the stream. If we immediately wait for an idle state after increasting the time it will immediately say that it is idle, even though any potential timers have not yet been triggered.
By waiting for up to 1 second to see if the engine has started processing again we can make sure the timers have been triggered. After this we still need to wait until the engine is idle again, to not modify the existing functionality.

qa/src/test/java/io/camunda/zeebe/process/test/qa/regular/assertions/MessageAssertTest.java

@@ -94,7 +94,7 @@ void testHasMessageStartEventNotBeenCorrelated() {
     }
 
     @Test
-    void testHasExpired() {
+    void testHasExpired() throws InterruptedException {
       // given
       Utilities.deployProcess(client, ProcessPackMessageEvent.RESOURCE_NAME);
       final Duration timeToLive = Duration.ofDays(1);
@@ -260,7 +260,7 @@ void testHasExpiredFailure() {
     }
 
     @Test
-    void testHasNotExpiredFailure() {
+    void testHasNotExpiredFailure() throws InterruptedException {
       // given
       Utilities.deployProcess(client, ProcessPackMessageEvent.RESOURCE_NAME);
       final Duration timeToLive = Duration.ofDays(1);

qa/src/test/java/io/camunda/zeebe/process/test/qa/regular/inspections/ProcessEventInspectionsTest.java

@@ -23,7 +23,7 @@ class ProcessEventInspectionsTest {
   private InMemoryEngine engine;
 
   @Test
-  void testFindFirstProcessInstance() {
+  void testFindFirstProcessInstance() throws InterruptedException {
     // given
     final DeploymentEvent deploymentEvent =
         Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
@@ -43,7 +43,7 @@ void testFindFirstProcessInstance() {
   }
 
   @Test
-  void testFindLastProcessInstance() {
+  void testFindLastProcessInstance() throws InterruptedException {
     // given
     final DeploymentEvent deploymentEvent =
         Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
@@ -63,7 +63,7 @@ void testFindLastProcessInstance() {
   }
 
   @Test
-  void testFindFirstProcessInstance_wrongTimer() {
+  void testFindFirstProcessInstance_wrongTimer() throws InterruptedException {
     // given
     Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
 
@@ -79,7 +79,7 @@ void testFindFirstProcessInstance_wrongTimer() {
   }
 
   @Test
-  void testFindProcessInstance_highIndex() {
+  void testFindProcessInstance_highIndex() throws InterruptedException {
     // given
     Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
 

qa/src/test/java/io/camunda/zeebe/process/test/qa/testcontainer/assertions/MessageAssertTest.java

@@ -94,7 +94,7 @@ void testHasMessageStartEventNotBeenCorrelated() {
     }
 
     @Test
-    void testHasExpired() {
+    void testHasExpired() throws InterruptedException {
       // given
       Utilities.deployProcess(client, ProcessPackMessageEvent.RESOURCE_NAME);
       final Duration timeToLive = Duration.ofDays(1);
@@ -260,7 +260,7 @@ void testHasExpiredFailure() {
     }
 
     @Test
-    void testHasNotExpiredFailure() {
+    void testHasNotExpiredFailure() throws InterruptedException {
       // given
       Utilities.deployProcess(client, ProcessPackMessageEvent.RESOURCE_NAME);
       final Duration timeToLive = Duration.ofDays(1);

qa/src/test/java/io/camunda/zeebe/process/test/qa/testcontainer/inspections/ProcessEventInspectionsTest.java

@@ -23,7 +23,7 @@ class ProcessEventInspectionsTest {
   private InMemoryEngine engine;
 
   @Test
-  void testFindFirstProcessInstance() {
+  void testFindFirstProcessInstance() throws InterruptedException {
     // given
     final DeploymentEvent deploymentEvent =
         Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
@@ -43,7 +43,7 @@ void testFindFirstProcessInstance() {
   }
 
   @Test
-  void testFindLastProcessInstance() {
+  void testFindLastProcessInstance() throws InterruptedException {
     // given
     final DeploymentEvent deploymentEvent =
         Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
@@ -63,7 +63,7 @@ void testFindLastProcessInstance() {
   }
 
   @Test
-  void testFindFirstProcessInstance_wrongTimer() {
+  void testFindFirstProcessInstance_wrongTimer() throws InterruptedException {
     // given
     Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
 
@@ -79,7 +79,7 @@ void testFindFirstProcessInstance_wrongTimer() {
   }
 
   @Test
-  void testFindProcessInstance_highIndex() {
+  void testFindProcessInstance_highIndex() throws InterruptedException {
     // given
     Utilities.deployProcess(client, ProcessPackTimerStartEvent.RESOURCE_NAME);
 

qa/src/test/java/io/camunda/zeebe/process/test/qa/util/Utilities.java

@@ -16,6 +16,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeoutException;
 import java.util.stream.Collectors;
 
 public class Utilities {
@@ -149,15 +150,16 @@ public static PublishMessageResponse sendMessage(
     return response;
   }
 
-  public static void increaseTime(final InMemoryEngine engine, final Duration duration) {
+  public static void increaseTime(final InMemoryEngine engine, final Duration duration)
+      throws InterruptedException {
     engine.increaseTime(duration);
     try {
-      // we need to wait some physical time so that InMemoryEngine has a chance to fire the timers
-      Thread.sleep(100);
-    } catch (InterruptedException e) {
-      // do nothing
+      engine.waitForProcessingState(Duration.ofMillis(250));
+      waitForIdleState(engine);
+    } catch (TimeoutException e) {
+      // Do nothing. We've waited up to 250 ms for processing to start, if it didn't start in this
+      // time the engine probably has not got anything left to process.
     }
-    waitForIdleState(engine);
   }
 
   public static void completeTask(