diff --git a/models/resources/purchase_resource/purchase_resource.go b/models/resources/purchase_resource/purchase_resource.go index cccb3b0..a7496f8 100644 --- a/models/resources/purchase_resource/purchase_resource.go +++ b/models/resources/purchase_resource/purchase_resource.go @@ -10,6 +10,7 @@ import ( type PurchaseResource struct { utils.AbstractObject DestPeerID string + ExecutionsID string `json:"executions_id,omitempty" bson:"executions_id,omitempty" validate:"required"` // ExecutionsID is the ID of the executions EndDate *time.Time `json:"end_buying_date,omitempty" bson:"end_buying_date,omitempty"` ResourceID string `json:"resource_id" bson:"resource_id" validate:"required"` ResourceType tools.DataType `json:"resource_type" bson:"resource_type" validate:"required"` diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go index 06840de..cb70b24 100755 --- a/models/workflow_execution/workflow_execution.go +++ b/models/workflow_execution/workflow_execution.go @@ -147,6 +147,7 @@ func (d *WorkflowExecution) buyEach(bs pricing.BillingStrategy, executionsID str UUID: uuid.New().String(), Name: d.GetName() + "_" + executionsID + "_" + wfID, }, + ExecutionsID: executionsID, DestPeerID: priced.GetCreatorID(), ResourceID: priced.GetID(), ResourceType: dt,