diff --git a/sys/workflow/engine.go b/sys/workflow/engine.go index d227fcf4a..daa998f5d 100644 --- a/sys/workflow/engine.go +++ b/sys/workflow/engine.go @@ -370,7 +370,7 @@ func (me *Engine) removeUselessNodes(ctx *context) error { filteredNodes[name] = item } } - + ctx.flow.Nodes = filteredNodes return nil diff --git a/sys/workflow/workflow.go b/sys/workflow/workflow.go index 0aace00cb..ca2db3438 100644 --- a/sys/workflow/workflow.go +++ b/sys/workflow/workflow.go @@ -90,7 +90,7 @@ func newWorkflow(wf *Workflow, engine *Engine, parent *context) (*context, error if err != nil { return nil, err } - + err = engine.setupNodes(&me) if err != nil { return nil, err