diff --git a/models/workflow/workflow.go b/models/workflow/workflow.go index 19f7fa1..f5359e3 100644 --- a/models/workflow/workflow.go +++ b/models/workflow/workflow.go @@ -26,6 +26,15 @@ type AbstractWorkflow struct { Shared []string `json:"shared,omitempty" bson:"shared,omitempty"` // Shared is the ID of the shared workflow } +func (w *AbstractWorkflow) getWorkflows() (list_computings []graph.GraphItem) { + for _, item := range w.Graph.Items { + if item.Workflow != nil { + list_computings = append(list_computings, item) + } + } + return +} + func (w *AbstractWorkflow) GetStoragesByRelatedProcessing(processingID string, relatedToData bool, ignoreRelation bool) (map[string][]utils.DBObject, map[string]map[string][]utils.DBObject) { storages := make(map[string][]utils.DBObject) datasRelatedToStorage := make(map[string]map[string][]utils.DBObject) @@ -93,7 +102,7 @@ func (w *AbstractWorkflow) GetDatasByRelatedProcessing(dataID string, relatedToS return datas, datasRelatedToData } -func (w *AbstractWorkflow) getProcessingsByRelatedProcessing() (list_computings []graph.GraphItem) { +func (w *AbstractWorkflow) getProcessings() (list_computings []graph.GraphItem) { for _, item := range w.Graph.Items { if item.Processing != nil { list_computings = append(list_computings, item)