fix(core): add predestroy to prevent Scheduler from crashing the whol…

…e app when context stops
kestra-io · Jul 24, 2023 · 426814d · 426814d
1 parent 39877a8
commit 426814d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/src/main/java/io/kestra/core/schedulers/AbstractScheduler.java b/core/src/main/java/io/kestra/core/schedulers/AbstractScheduler.java
@@ -27,6 +27,7 @@
 import io.kestra.core.utils.ListUtils;
 import io.micronaut.context.ApplicationContext;
 import io.micronaut.inject.qualifiers.Qualifiers;
+import jakarta.annotation.PreDestroy;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -588,6 +589,7 @@ private void sendPollingTriggerToWorker(FlowWithPollingTrigger flowWithTrigger)
     }
 
     @Override
+    @PreDestroy
     public void close() {
         this.scheduleExecutor.shutdown();
     }