From 10d186c79f1bb26a5391f92cbaa223d3b5132c69 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= <loikeseke@gmail.com>
Date: Fri, 30 Jun 2023 15:27:13 +0200
Subject: [PATCH] fix: trigger test

---
 src/test/java/io/kestra/plugin/aws/s3/TriggerTest.java  | 2 +-
 src/test/java/io/kestra/plugin/aws/sqs/TriggerTest.java | 2 +-
 2 files changed, 2 insertions(+), 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
index 8155817c..4905fe3e 100644
--- 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
index 0bcffe7b..ca067d08 100644
--- 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<>();