[Fix #1414] Gonzalos comments

Author: fjtirado

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

@@ -71,16 +71,15 @@ protected TryExecutorBuilder(
       this.errorFilter = buildErrorFilter(catchInfo.getErrors());
       this.whenFilter = WorkflowUtils.optionalPredicate(application, catchInfo.getWhen());
       this.exceptFilter = WorkflowUtils.optionalPredicate(application, catchInfo.getExceptWhen());
-      this.taskExecutor =
-          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.copy(), catchTaskDo, definition))
+                    TaskExecutorHelper.createExecutorList(
+                        position.copy().addProperty("catch"), catchTaskDo, definition))
                 : Optional.empty();
 
         Retry retry = catchTask.getRetry();
@@ -89,6 +88,8 @@ protected TryExecutorBuilder(
         this.catchTaskExecutor = Optional.empty();
         this.retryIntervalExecutor = Optional.empty();
       }
+      this.taskExecutor =
+          TaskExecutorHelper.createExecutorList(position, task.getTry(), definition, "try");
     }
 
     private Optional<RetryExecutor> buildRetryInterval(Retry retry) {

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

@@ -20,7 +20,7 @@
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
 import com.fasterxml.jackson.databind.JsonNode;
-import io.serverlessworkflow.api.types.TryTask;
+import io.serverlessworkflow.impl.TaskContextData;
 import io.serverlessworkflow.impl.WorkflowApplication;
 import io.serverlessworkflow.impl.WorkflowException;
 import io.serverlessworkflow.impl.WorkflowModel;
@@ -31,6 +31,7 @@
 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;
@@ -65,17 +66,18 @@ void tearDown() throws IOException {
   private class RetryListener implements WorkflowExecutionListener {
 
     private Map<String, Short> taskRetried = new ConcurrentHashMap<>();
-    private Map<String, Short> tryTaskCompleted = new ConcurrentHashMap<>();
+    private Map<String, Short> taskCompleted = new ConcurrentHashMap<>();
+    private Set<String> raiseTaskPos = ConcurrentHashMap.newKeySet();
 
+    @Override
     public void onTaskRetried(TaskRetriedEvent ev) {
       taskRetried.put(ev.taskContext().position().jsonPointer(), ev.taskContext().retryAttempt());
     }
 
+    @Override
     public void onTaskCompleted(TaskCompletedEvent ev) {
-      if (ev.taskContext().task() instanceof TryTask) {
-        tryTaskCompleted.put(
-            ev.taskContext().position().jsonPointer(), ev.taskContext().retryAttempt());
-      }
+      TaskContextData taskContext = ev.taskContext();
+      taskCompleted.put(taskContext.position().jsonPointer(), taskContext.retryAttempt());
     }
   }
 
@@ -103,7 +105,6 @@ void testRetry(String path) throws IOException {
         .until(() -> future.join().as(JsonNode.class).orElseThrow().equals(result));
     assertThat(retryListener.taskRetried).hasSize(1);
     assertThat(retryListener.taskRetried.get("do/0/tryGetPet/try/0/getPet")).isEqualTo((short) 2);
-    assertThat(retryListener.tryTaskCompleted.values()).containsOnly((short) 0);
   }
 
   @Test
@@ -136,9 +137,9 @@ void testNestedRetry() throws IOException {
             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"))
+    assertThat(retryListener.taskCompleted.get("do/0/tryServerError/try/0/tryCommunication/try"))
         .isEqualTo((short) 2);
-    assertThat(retryListener.tryTaskCompleted.get("do/0/tryServerError/try")).isEqualTo((short) 0);
+    assertThat(retryListener.taskCompleted.get("do/0/tryServerError/try")).isEqualTo((short) 0);
   }
 
   @Test
@@ -158,7 +159,9 @@ void testRetryDo() throws IOException {
                     .orElseThrow()
                     .equals(Map.of("setAfterFailingTask", "No problem")));
 
-    assertThat(retryListener.tryTaskCompleted.get("do/0/attemptTask/try")).isEqualTo((short) 0);
+    assertThat(retryListener.taskCompleted.get("do/0/attemptTask/try")).isEqualTo((short) 0);
+    assertThat(retryListener.taskCompleted)
+        .containsKey("do/0/attemptTask/catch/do/0/executeAfterFailingTask");
   }
 
   @Test