chore(test): fix worker api

kestra-io · Mar 27, 2024 · e921ec1 · e921ec1
1 parent 672e8ba
commit e921ec1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/test/java/io/kestra/plugin/redis/TriggerListTest.java b/src/test/java/io/kestra/plugin/redis/TriggerListTest.java
@@ -10,6 +10,7 @@
 import io.kestra.core.schedulers.AbstractScheduler;
 import io.kestra.core.schedulers.DefaultScheduler;
 import io.kestra.core.schedulers.SchedulerTriggerStateInterface;
+import io.kestra.core.utils.IdUtils;
 import io.kestra.core.utils.TestsUtils;
 import io.micronaut.context.ApplicationContext;
 import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
@@ -54,13 +55,13 @@ class TriggerListTest {
     void flow() throws Exception {
         CountDownLatch queueCount = new CountDownLatch(1);
 
-        Worker worker = new Worker(applicationContext, 8, null);
         try (
             AbstractScheduler scheduler = new DefaultScheduler(
                 this.applicationContext,
                 this.flowListenersService,
                 this.triggerState
             );
+            Worker worker = applicationContext.createBean(Worker.class, IdUtils.create(), 8, null)
         ) {
             AtomicReference<Execution> last = new AtomicReference<>();