fix(kafka-runner): don't wait too long if flow is not defined

kestra-io · Nov 4, 2022 · 4603417 · 4603417
1 parent 0f1b193
commit 4603417
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaStreamSourceService.java b/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaStreamSourceService.java
@@ -76,7 +76,7 @@ public Executor joinFlow(Executor executor, Boolean withDefaults) {
             flow = Await.until(
                 () -> flowExecutorInterface.findByExecution(executor.getExecution()).orElse(null),
                 Duration.ofMillis(100),
-                Duration.ofMinutes(5)
+                Duration.ofMinutes(flowExecutorInterface.isReady() ? 2 : 5)
             );
         } catch (TimeoutException e) {
             // execution is failed, can't find flow, avoid recursive exception, skipped it.