fix(core): prevent npe on subflow

kestra-io · Nov 29, 2023 · 701dd17 · 701dd17
1 parent 1e31af6
commit 701dd17
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/java/io/kestra/core/topologies/FlowTopologyService.java b/core/src/main/java/io/kestra/core/topologies/FlowTopologyService.java
@@ -165,7 +165,7 @@ protected boolean isFlowTaskChild(Flow parent, Flow child) {
                 .filter(t -> t instanceof ExecutableTask)
                 .map(t -> (ExecutableTask<?>) t)
                 .anyMatch(t ->
-                    t.subflowId().namespace().equals(child.getNamespace()) && t.subflowId().flowId().equals(child.getId())
+                    t.subflowId() != null && t.subflowId().namespace().equals(child.getNamespace()) && t.subflowId().flowId().equals(child.getId())
                 );
         } catch (Exception e) {
             log.warn("Failed to detect flow task on namespace:'" + parent.getNamespace() + "', flowId:'" + parent.getId()  + "'", e);