diff --git a/workflow_builder/argo_builder.go b/workflow_builder/argo_builder.go index 8da03b8..be184b5 100644 --- a/workflow_builder/argo_builder.go +++ b/workflow_builder/argo_builder.go @@ -160,7 +160,7 @@ func (b *ArgoBuilder) createNginxVolumes() { func (b *ArgoBuilder) getDependency(current_computing_id string) (dependencies []string) { for _, link := range b.OriginWorkflow.Graph.Links { - if !b.IsProcessing(link.Source.ID) { + if b.OriginWorkflow.Graph.Items[link.Source.ID].Processing == nil { continue } source := b.OriginWorkflow.Graph.Items[link.Source.ID].Processing