Fixing test duration (#911)

Signed-off-by: fjtirado <[email protected]>

Author: fjtirado

impl/test/src/test/java/io/serverlessworkflow/impl/test/RetryTest.java

@@ -81,7 +81,7 @@ void testRetry(String path) throws IOException {
             .instance(Map.of("delay", 0.01))
             .start();
     Awaitility.await()
-        .atMost(Duration.ofSeconds(100))
+        .atMost(Duration.ofSeconds(1))
         .until(() -> future.join().as(JsonNode.class).orElseThrow().equals(result));
   }
 }

impl/test/src/test/java/io/serverlessworkflow/impl/test/ScheduleEventConsumerTest.java

@@ -54,7 +54,6 @@ void tearDown() throws IOException {
 
   @Test
   void testAllEvent() throws IOException, InterruptedException, ExecutionException {
-
     WorkflowDefinition definition =
         appl.workflowDefinition(
             readWorkflowFromClasspath("workflows-samples/listen-start-all.yaml"));
@@ -63,7 +62,7 @@ void testAllEvent() throws IOException, InterruptedException, ExecutionException
     appl.eventPublishers().forEach(p -> p.publish(buildCloudEvent(Map.of("name", "Fulanito"))));
     await()
         .pollDelay(Duration.ofMillis(20))
-        .atMost(Duration.ofMillis(500))
+        .atMost(Duration.ofMillis(600))
         .until(
             () ->
                 instances.stream().filter(i -> i.status() == WorkflowStatus.COMPLETED).count()
@@ -81,7 +80,7 @@ void testOneEvent() throws IOException, InterruptedException, ExecutionException
     Collection<WorkflowInstance> instances = appl.scheduler().scheduledInstances(definition);
     await()
         .pollDelay(Duration.ofMillis(20))
-        .atMost(Duration.ofMillis(500))
+        .atMost(Duration.ofMillis(600))
         .until(
             () ->
                 instances.stream().filter(i -> i.status() == WorkflowStatus.COMPLETED).count()
@@ -105,7 +104,7 @@ void testTogether() throws IOException, InterruptedException, ExecutionException
     Collection<WorkflowInstance> allDefInstances = appl.scheduler().scheduledInstances(allDef);
     await()
         .pollDelay(Duration.ofMillis(20))
-        .atMost(Duration.ofMillis(500))
+        .atMost(Duration.ofMillis(800))
         .until(
             () ->
                 oneDefInstances.stream().filter(i -> i.status() == WorkflowStatus.COMPLETED).count()