diff --git a/models/workflow/workflow.go b/models/workflow/workflow.go index 880d720..5f23b21 100644 --- a/models/workflow/workflow.go +++ b/models/workflow/workflow.go @@ -110,13 +110,13 @@ func (w *Workflow) GetByRelatedProcessing(processingID string, g func(item graph _, node = item.GetResource() // we are looking for the storage as destination } if processingID == nodeID && node != nil { // if the storage is linked to the processing - if _, ok := related[processingID]; !ok { + if _, ok := related[node.GetID()]; !ok { related[processingID] = Related{} } rel := related[node.GetID()] rel.Node = node rel.Links = append(rel.Links, link) - related[processingID] = rel + related[node.GetID()] = rel } } return related