From c878db5200869b4a015056a839b5599298ad1244 Mon Sep 17 00:00:00 2001 From: Haytham AbuelFutuh Date: Mon, 27 Jan 2020 09:48:50 -0800 Subject: [PATCH] Dynamic sub-nodes should have retry attempt in the output dir path (#59) --- flytepropeller/pkg/controller/nodes/dynamic/handler.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flytepropeller/pkg/controller/nodes/dynamic/handler.go b/flytepropeller/pkg/controller/nodes/dynamic/handler.go index 60287cdc7..f2a0c8649 100644 --- a/flytepropeller/pkg/controller/nodes/dynamic/handler.go +++ b/flytepropeller/pkg/controller/nodes/dynamic/handler.go @@ -240,10 +240,12 @@ func (d dynamicNodeTaskNodeHandler) buildDynamicWorkflowTemplate(ctx context.Con if err != nil { return nil, err } - outputDir, err := nCtx.DataStore().ConstructReference(ctx, originalNodePath, "0") + + outputDir, err := nCtx.DataStore().ConstructReference(ctx, originalNodePath, currentAttemptStr) if err != nil { return nil, err } + subNodeStatus.SetDataDir(originalNodePath) subNodeStatus.SetOutputDir(outputDir) n.Id = newID