From 80c1c59bb99bed15856b7359901f106083a3ed15 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Thu, 16 Nov 2023 20:47:05 -0800 Subject: [PATCH] compile failure node Signed-off-by: Kevin Su --- flytepropeller/pkg/compiler/requirements.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flytepropeller/pkg/compiler/requirements.go b/flytepropeller/pkg/compiler/requirements.go index 59243554d3..14b1778e38 100644 --- a/flytepropeller/pkg/compiler/requirements.go +++ b/flytepropeller/pkg/compiler/requirements.go @@ -60,6 +60,9 @@ func updateWorkflowRequirements(workflow *core.WorkflowTemplate, subWfs common.W for _, node := range workflow.Nodes { updateNodeRequirements(node, subWfs, taskIds, workflowIds, followSubworkflows, errs) } + if workflow.FailureNode != nil { + updateNodeRequirements(workflow.FailureNode, subWfs, taskIds, workflowIds, followSubworkflows, errs) + } } func updateNodeRequirements(node *flyteNode, subWfs common.WorkflowIndex, taskIds, workflowIds common.IdentifierSet,