add workflow func tools
This commit is contained in:
parent
3388fcc6f3
commit
c083ce748c
@ -26,7 +26,7 @@ type AbstractWorkflow struct {
|
|||||||
Shared []string `json:"shared,omitempty" bson:"shared,omitempty"` // Shared is the ID of the shared workflow
|
Shared []string `json:"shared,omitempty" bson:"shared,omitempty"` // Shared is the ID of the shared workflow
|
||||||
}
|
}
|
||||||
|
|
||||||
func (w *AbstractWorkflow) getWorkflows() (list_computings []graph.GraphItem) {
|
func (w *AbstractWorkflow) GetWorkflows() (list_computings []graph.GraphItem) {
|
||||||
for _, item := range w.Graph.Items {
|
for _, item := range w.Graph.Items {
|
||||||
if item.Workflow != nil {
|
if item.Workflow != nil {
|
||||||
list_computings = append(list_computings, item)
|
list_computings = append(list_computings, item)
|
||||||
@ -102,7 +102,7 @@ func (w *AbstractWorkflow) GetDatasByRelatedProcessing(dataID string, relatedToS
|
|||||||
return datas, datasRelatedToData
|
return datas, datasRelatedToData
|
||||||
}
|
}
|
||||||
|
|
||||||
func (w *AbstractWorkflow) getProcessings() (list_computings []graph.GraphItem) {
|
func (w *AbstractWorkflow) GetProcessings() (list_computings []graph.GraphItem) {
|
||||||
for _, item := range w.Graph.Items {
|
for _, item := range w.Graph.Items {
|
||||||
if item.Processing != nil {
|
if item.Processing != nil {
|
||||||
list_computings = append(list_computings, item)
|
list_computings = append(list_computings, item)
|
||||||
|
Loading…
Reference in New Issue
Block a user