test: put retry on SchedulerTriggerChangeTest.run

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

@@ -435,7 +435,7 @@ public abstract class AbstractRunnerTest {
         flowConcurrencyCaseTest.flowConcurrencyCancelPause();
     }
 
-    @Test
+    @RetryingTest(5)
     @LoadFlows({"flows/valids/flow-concurrency-for-each-item.yaml", "flows/valids/flow-concurrency-queue.yml"})
     protected void flowConcurrencyWithForEachItem() throws Exception {
         flowConcurrencyCaseTest.flowConcurrencyWithForEachItem();

core/src/test/java/io/kestra/plugin/core/execution/ExitTest.java

@@ -14,6 +14,7 @@ import io.kestra.core.utils.TestsUtils;
 import jakarta.inject.Inject;
 import jakarta.inject.Named;
 import org.junit.jupiter.api.Test;
+import org.junitpioneer.jupiter.RetryingTest;
 import reactor.core.publisher.Flux;
 
 import java.util.Optional;
@@ -42,7 +43,7 @@ class ExitTest {
         assertThat(execution.getTaskRunList().getFirst().getState().getCurrent()).isEqualTo(State.Type.WARNING);
     }
 
-    @Test
+    @RetryingTest(5)
     @LoadFlows("flows/valids/exit-killed.yaml")
     void shouldExitAndKillTheExecution() throws QueueException, InterruptedException {
         CountDownLatch countDownLatch = new CountDownLatch(2);// We need to wait for 3 execution modifications to be sure all tasks are passed to KILLED

scheduler/src/test/java/io/kestra/scheduler/SchedulerTriggerChangeTest.java

@@ -30,7 +30,7 @@ import jakarta.inject.Inject;
 import jakarta.inject.Named;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
-import org.junit.jupiter.api.Test;
+import org.junitpioneer.jupiter.RetryingTest;
 import reactor.core.publisher.Flux;
 
 import java.time.Duration;
@@ -88,7 +88,7 @@ public class SchedulerTriggerChangeTest extends AbstractSchedulerTest {
         return FlowWithSource.of(flow, flow.getSource());
     }
 
-    @Test
+    @RetryingTest(5)
     void run() throws Exception {
         CountDownLatch executionQueueCount = new CountDownLatch(1);
         CountDownLatch executionKilledCount = new CountDownLatch(1);