[Fix #1414] Use try rather than do as position name

Signed-off-by: fjtirado <ftirados@ibm.com>

Author: fjtirado

impl/core/src/main/java/io/serverlessworkflow/impl/executors/TaskExecutorHelper.java

@@ -61,8 +61,16 @@ public static TaskExecutor<?> createExecutorList(
       WorkflowMutablePosition position,
       List<TaskItem> taskItems,
       WorkflowDefinition workflowDefinition) {
+    return createExecutorList(position, taskItems, workflowDefinition, "do");
+  }
+
+  public static TaskExecutor<?> createExecutorList(
+      WorkflowMutablePosition position,
+      List<TaskItem> taskItems,
+      WorkflowDefinition workflowDefinition,
+      String positionPrefix) {
     Map<String, TaskExecutorBuilder<?>> executors =
-        createExecutorBuilderList(position, taskItems, workflowDefinition, "do");
+        createExecutorBuilderList(position, taskItems, workflowDefinition, positionPrefix);
     executors.values().forEach(t -> t.connect(executors));
     Iterator<TaskExecutorBuilder<?>> iter = executors.values().iterator();
     TaskExecutor<?> first = iter.next().build();

impl/core/src/main/java/io/serverlessworkflow/impl/executors/TryExecutor.java

@@ -72,15 +72,15 @@ protected TryExecutorBuilder(
       this.whenFilter = WorkflowUtils.optionalPredicate(application, catchInfo.getWhen());
       this.exceptFilter = WorkflowUtils.optionalPredicate(application, catchInfo.getExceptWhen());
       this.taskExecutor =
-          TaskExecutorHelper.createExecutorList(position, task.getTry(), definition);
+          TaskExecutorHelper.createExecutorList(position, task.getTry(), definition, "try");
       TryTaskCatch catchTask = task.getCatch();
       if (catchTask != null) {
         this.errorVariable = catchTask.getAs();
         List<TaskItem> catchTaskDo = catchTask.getDo();
         this.catchTaskExecutor =
             catchTaskDo != null && !catchTaskDo.isEmpty()
                 ? Optional.of(
-                    TaskExecutorHelper.createExecutorList(position, catchTaskDo, definition))
+                    TaskExecutorHelper.createExecutorList(position.copy(), catchTaskDo, definition))
                 : Optional.empty();
 
         Retry retry = catchTask.getRetry();

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

@@ -27,12 +27,10 @@
 import io.serverlessworkflow.impl.jackson.JsonUtils;
 import io.serverlessworkflow.impl.lifecycle.TaskCompletedEvent;
 import io.serverlessworkflow.impl.lifecycle.TaskRetriedEvent;
-import io.serverlessworkflow.impl.lifecycle.TraceExecutionListener;
 import io.serverlessworkflow.impl.lifecycle.WorkflowExecutionListener;
 import java.io.IOException;
 import java.time.Duration;
 import java.util.Map;
-import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentHashMap;
 import okhttp3.mockwebserver.MockResponse;
@@ -55,11 +53,7 @@ void setUp() throws IOException {
     apiServer = new MockWebServer();
     apiServer.start(9797);
     retryListener = new RetryListener();
-    app =
-        WorkflowApplication.builder()
-            .withListener(retryListener)
-            .withListener(new TraceExecutionListener())
-            .build();
+    app = WorkflowApplication.builder().withListener(retryListener).build();
   }
 
   @AfterEach
@@ -71,15 +65,16 @@ void tearDown() throws IOException {
   private class RetryListener implements WorkflowExecutionListener {
 
     private Map<String, Short> taskRetried = new ConcurrentHashMap<>();
-    private Set<Short> contexts = ConcurrentHashMap.newKeySet();
+    private Map<String, Short> tryTaskCompleted = new ConcurrentHashMap<>();
 
     public void onTaskRetried(TaskRetriedEvent ev) {
       taskRetried.put(ev.taskContext().position().jsonPointer(), ev.taskContext().retryAttempt());
     }
 
     public void onTaskCompleted(TaskCompletedEvent ev) {
       if (ev.taskContext().task() instanceof TryTask) {
-        contexts.add(ev.taskContext().retryAttempt());
+        tryTaskCompleted.put(
+            ev.taskContext().position().jsonPointer(), ev.taskContext().retryAttempt());
       }
     }
   }
@@ -107,8 +102,8 @@ void testRetry(String path) throws IOException {
         .atMost(Duration.ofSeconds(1))
         .until(() -> future.join().as(JsonNode.class).orElseThrow().equals(result));
     assertThat(retryListener.taskRetried).hasSize(1);
-    assertThat(retryListener.taskRetried.get("do/0/tryGetPet/do/0/getPet")).isEqualTo((short) 2);
-    assertThat(retryListener.contexts).containsOnly((short) 0);
+    assertThat(retryListener.taskRetried.get("do/0/tryGetPet/try/0/getPet")).isEqualTo((short) 2);
+    assertThat(retryListener.tryTaskCompleted.values()).containsOnly((short) 0);
   }
 
   @Test
@@ -135,8 +130,35 @@ void testNestedRetry() throws IOException {
         .atMost(Duration.ofSeconds(1))
         .until(() -> future.join().as(JsonNode.class).orElseThrow().equals(result));
     assertThat(retryListener.taskRetried).hasSize(2);
-    assertThat(retryListener.taskRetried.values()).containsExactlyInAnyOrder((short) 5, (short) 2);
-    assertThat(retryListener.contexts).containsExactlyInAnyOrder((short) 0, (short) 2);
+    assertThat(retryListener.taskRetried.get("do/0/tryServerError/try/0/tryCommunication/try"))
+        .isEqualTo((short) 2);
+    assertThat(
+            retryListener.taskRetried.get(
+                "do/0/tryServerError/try/0/tryCommunication/try/0/getPet"))
+        .isEqualTo((short) 5);
+    assertThat(retryListener.tryTaskCompleted.get("do/0/tryServerError/try/0/tryCommunication/try"))
+        .isEqualTo((short) 2);
+    assertThat(retryListener.tryTaskCompleted.get("do/0/tryServerError/try")).isEqualTo((short) 0);
+  }
+
+  @Test
+  void testRetryDo() throws IOException {
+    CompletableFuture<WorkflowModel> future =
+        app.workflowDefinition(
+                readWorkflowFromClasspath("workflows-samples/try-catch-with-do.yaml"))
+            .instance(Map.of("delay", 0.01))
+            .start();
+    Awaitility.await()
+        .atMost(Duration.ofSeconds(1))
+        .until(
+            () ->
+                future
+                    .join()
+                    .asMap()
+                    .orElseThrow()
+                    .equals(Map.of("setAfterFailingTask", "No problem")));
+
+    assertThat(retryListener.tryTaskCompleted.get("do/0/attemptTask/try")).isEqualTo((short) 0);
   }
 
   @Test

impl/test/src/test/resources/workflows-samples/try-catch-with-do.yaml

@@ -0,0 +1,22 @@
+document:
+  dsl: '1.0.0-alpha5'
+  namespace: acme
+  name: try-catch-with-do
+  version: '0.1.0'
+do:
+  - attemptTask:
+      try:
+        - failingTask:
+            raise:
+              error:
+                type: https://example.com/errors/runtime
+                status: 500
+      catch:
+        errors:
+          with:
+            type: https://example.com/errors/runtime
+            status: 500
+        do:
+          - executeAfterFailingTask:
+              set:
+                setAfterFailingTask: "No problem"