fix(test): don't emit replay execution from TestRunnerUtils.awaitChildExecution

Author: brian-mulier-p

core/src/test/java/io/kestra/core/runners/RestartCaseTest.java

@@ -149,10 +149,10 @@ public void replay() throws Exception {
 
         assertThat(restartedExec.getId()).isNotEqualTo(firstExecution.getId());
         assertThat(restartedExec.getTaskRunList().get(1).getId()).isNotEqualTo(firstExecution.getTaskRunList().get(1).getId());
-        Execution finishedRestartedExecution = runnerUtils.awaitChildExecution(
+        Execution finishedRestartedExecution = runnerUtils.emitAndAwaitChildExecution(
             flow,
             firstExecution,
-            restartedExec,
+            restartedExec.withTenantId(MAIN_TENANT),
             Duration.ofSeconds(60)
         );
 
@@ -315,10 +315,10 @@ public void restartOrReplayLoopUntil() throws Exception{
         assertThat(replayedExecution.getState().getCurrent()).isEqualTo(Type.RESTARTED);
         assertThat(replayedExecution.getId()).isNotEqualTo(firstExecution.getId());
 
-        Execution finalReplayedExecution = runnerUtils.awaitChildExecution(
+        Execution finalReplayedExecution = runnerUtils.emitAndAwaitChildExecution(
             flow,
             firstExecution,
-            replayedExecution,
+            replayedExecution.withTenantId(MAIN_TENANT),
             Duration.ofSeconds(60)
         );
         assertThat(finalReplayedExecution.getState().getCurrent()).isEqualTo(Type.FAILED);

tests/src/main/java/io/kestra/core/runners/TestRunnerUtils.java

@@ -364,11 +364,14 @@ public Execution killExecution(Execution execution) throws QueueException {
         ), execution);
     }
 
-    public Execution awaitChildExecution(Flow flow, Execution parentExecution, Execution execution, Duration duration)
-        throws QueueException {
+    public Execution emitAndAwaitChildExecution(Flow flow, Execution parentExecution, Execution execution, Duration duration) throws QueueException {
         return this.emitAndAwaitExecution(isTerminatedChildExecution(parentExecution, flow), execution, duration);
     }
 
+    public Execution awaitChildExecution(Flow flow, Execution parentExecution, Execution execution, Duration duration) {
+        return this.awaitExecution(isTerminatedChildExecution(parentExecution, flow), execution, duration);
+    }
+
     private Predicate<Execution> isTerminatedExecution(Execution execution, Flow flow) {
         return e -> e.getId().equals(execution.getId()) && executionService.isTerminated(flow, e);
     }

webserver/src/test/java/io/kestra/webserver/controllers/api/ExecutionControllerRunnerTest.java

@@ -672,7 +672,7 @@ void restartExecutionFromTaskIdWithSequential() throws Exception {
         runnerUtils.awaitChildExecution(
             flow.get(),
             parentExecution,
-            createdChidExec,
+            createdChidExec.withTenantId(TENANT_ID),
             Duration.ofSeconds(30));
     }