fix: trigger test

kestra-io · Jun 30, 2023 · 61cf822 · 61cf822
1 parent 410ce05
commit 61cf822
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/io/kestra/plugin/nats/TriggerTest.java b/src/test/java/io/kestra/plugin/nats/TriggerTest.java
@@ -84,13 +84,13 @@ protected Execution triggerFlow() 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<>();