diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index f313fc8..a42c2c9 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -118,6 +118,7 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w continue } resp, err := wfa.Caller.CallPost(p.(*peer.Peer).Url, methods[tools.POST], (&workflow_execution.WorkflowExecutions{ + ResourceID: dc_id, Executions: execs, }).Serialize()) if err != nil { diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go index 5df5a61..6183df3 100644 --- a/models/workflow_execution/workflow_execution.go +++ b/models/workflow_execution/workflow_execution.go @@ -40,6 +40,7 @@ func (d ScheduledType) EnumIndex() int { } type WorkflowExecutions struct { + ResourceID string `json:"resource_id" bson:"resource_id"` Executions []*WorkflowExecution `json:"executions" bson:"executions"` }