fix: trigger test

kestra-io · Jun 30, 2023 · 10d186c · 10d186c
1 parent dfe512d
commit 10d186c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/test/java/io/kestra/plugin/aws/s3/TriggerTest.java b/src/test/java/io/kestra/plugin/aws/s3/TriggerTest.java
@@ -52,13 +52,13 @@ void flow() throws Exception {
         CountDownLatch queueCount = new CountDownLatch(1);
 
         // scheduler
+        Worker worker = new Worker(applicationContext, 8, null);
         try (
             AbstractScheduler scheduler = new DefaultScheduler(
                 this.applicationContext,
                 this.flowListenersService,
                 this.triggerState
             );
-            Worker worker = new Worker(applicationContext, 8, null);
         ) {
             AtomicReference<Execution> last = new AtomicReference<>();
 

diff --git a/src/test/java/io/kestra/plugin/aws/sqs/TriggerTest.java b/src/test/java/io/kestra/plugin/aws/sqs/TriggerTest.java
@@ -54,13 +54,13 @@ void flow() throws Exception {
         CountDownLatch queueCount = new CountDownLatch(1);
 
         // scheduler
+        Worker worker = new Worker(applicationContext, 8, null);
         try (
             AbstractScheduler scheduler = new DefaultScheduler(
                 this.applicationContext,
                 this.flowListenersService,
                 this.triggerState
             );
-            Worker worker = new Worker(applicationContext, 8, null);
         ) {
             AtomicReference<Execution> last = new AtomicReference<>();