fix(cli): restore-queue try to send invalid flow to queue

kestra-io · Feb 8, 2022 · 06896b8 · 06896b8
1 parent 0b31a59
commit 06896b8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cli/src/main/java/io/kestra/cli/services/RestoreQueueService.java b/cli/src/main/java/io/kestra/cli/services/RestoreQueueService.java
@@ -1,6 +1,7 @@
 package io.kestra.cli.services;
 
 import io.kestra.core.models.flows.Flow;
+import io.kestra.core.models.flows.FlowSource;
 import io.kestra.core.models.templates.Template;
 import io.kestra.core.models.triggers.Trigger;
 import io.kestra.core.queues.QueueFactoryInterface;
@@ -32,6 +33,8 @@ public int flows(boolean noRecreate) {
             .findAll()
             .stream()
             .flatMap(flow -> flowRepository.findRevisions(flow.getNamespace(), flow.getId()).stream())
+            // we can't resend FlowSource since deserialize failed & will be invalid
+            .filter(flow -> !(flow instanceof FlowSource))
             .collect(Collectors.toList());
 
         return this.send(flows, QueueFactoryInterface.FLOW_NAMED, Flow.class, noRecreate);