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

Author: brian-mulier-p

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

@@ -152,7 +152,7 @@ public void replay() throws Exception {
         Execution finishedRestartedExecution = runnerUtils.awaitChildExecution(
             flow,
             firstExecution,
-            restartedExec,
+            restartedExec.withTenantId(MAIN_TENANT),
             Duration.ofSeconds(60)
         );
 
@@ -318,7 +318,7 @@ public void restartOrReplayLoopUntil() throws Exception{
         Execution finalReplayedExecution = runnerUtils.awaitChildExecution(
             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,9 +364,8 @@ public Execution killExecution(Execution execution) throws QueueException {
         ), execution);
     }
 
-    public Execution awaitChildExecution(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) {

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));
     }