diff --git a/models/workflow/workflow.go b/models/workflow/workflow.go index 5f23b21..61a70ad 100644 --- a/models/workflow/workflow.go +++ b/models/workflow/workflow.go @@ -110,13 +110,11 @@ 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[node.GetID()]; !ok { - related[processingID] = Related{} - } - rel := related[node.GetID()] + relID := node.GetID() + rel := Related{} rel.Node = node rel.Links = append(rel.Links, link) - related[node.GetID()] = rel + related[relID] = rel } } return related