fix(core): FlowWithPollingTrigger.from should check on PollingTrigger (…

…#2028)
kestra-io · Sep 15, 2023 · e85f697 · e85f697
1 parent 52d4bf2
commit e85f697
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/java/io/kestra/core/schedulers/AbstractScheduler.java b/core/src/main/java/io/kestra/core/schedulers/AbstractScheduler.java
@@ -613,7 +613,7 @@ private static class FlowWithPollingTrigger {
         public FlowWithPollingTrigger from(Flow flow) throws InternalException {
             AbstractTrigger abstractTrigger = flow.getTriggers()
                 .stream()
-                .filter(a -> a.getId().equals(this.trigger.getId()))
+                .filter(a -> a.getId().equals(this.trigger.getId()) && a instanceof PollingTriggerInterface)
                 .findFirst()
                 .orElseThrow(() -> new InternalException("Couldn't find the trigger '" + this.trigger.getId() + "' on flow '" + flow.uid() + "'"));