From 0e84db61deba6cb88eac0692f174bf4f42f63477 Mon Sep 17 00:00:00 2001 From: mr Date: Mon, 13 Jan 2025 12:06:28 +0100 Subject: [PATCH] add exec --- models/workflow_execution/workflow_execution.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go index c026faf..bb492d4 100644 --- a/models/workflow_execution/workflow_execution.go +++ b/models/workflow_execution/workflow_execution.go @@ -104,13 +104,13 @@ func (d *WorkflowExecutions) VerifyAuth(request *tools.APIRequest) bool { return true } -func (d *WorkflowExecutions) Book(priceds map[tools.DataType][]pricing.PricedItemITF, request *tools.APIRequest) []*booking.Booking { - booking := d.bookEach(tools.STORAGE_RESOURCE, priceds[tools.STORAGE_RESOURCE], request) - booking = append(booking, d.bookEach(tools.PROCESSING_RESOURCE, priceds[tools.PROCESSING_RESOURCE], request)...) +func (d *WorkflowExecutions) Book(priceds map[tools.DataType][]pricing.PricedItemITF) []*booking.Booking { + booking := d.bookEach(tools.STORAGE_RESOURCE, priceds[tools.STORAGE_RESOURCE]) + booking = append(booking, d.bookEach(tools.PROCESSING_RESOURCE, priceds[tools.PROCESSING_RESOURCE])...) return booking } -func (d *WorkflowExecutions) bookEach(dt tools.DataType, priceds []pricing.PricedItemITF, request *tools.APIRequest) []*booking.Booking { +func (d *WorkflowExecutions) bookEach(dt tools.DataType, priceds []pricing.PricedItemITF) []*booking.Booking { items := []*booking.Booking{} for _, priced := range priceds { start := d.ExecDate @@ -123,6 +123,7 @@ func (d *WorkflowExecutions) bookEach(dt tools.DataType, priceds []pricing.Price ResourceID: priced.GetID(), ResourceType: dt, DestPeerID: priced.GetCreatorID(), + ExecutionID: d.GetID(), ExpectedStartDate: start, ExpectedEndDate: &end, }