diff --git a/models/resources/storage.go b/models/resources/storage.go index 14d578c..f847182 100755 --- a/models/resources/storage.go +++ b/models/resources/storage.go @@ -46,6 +46,7 @@ type StorageResourceInstance struct { ResourceInstance[*StorageResourcePartnership] Credentials *Credentials `json:"credentials,omitempty" bson:"credentials,omitempty"` Source string `bson:"source,omitempty" json:"source,omitempty"` // Source is the source of the storage + Path string `bson:"path,omitempty" json:"path,omitempty"` // Path is the store folders in the source Local bool `bson:"local" json:"local"` SecurityLevel string `bson:"security_level,omitempty" json:"security_level,omitempty"` SizeType enum.StorageSize `bson:"size_type" json:"size_type" default:"0"` // SizeType is the type of the storage size diff --git a/models/workflow_execution/workflow_scheduler.go b/models/workflow_execution/workflow_scheduler.go index 4863010..e32947a 100755 --- a/models/workflow_execution/workflow_scheduler.go +++ b/models/workflow_execution/workflow_scheduler.go @@ -92,7 +92,7 @@ func (ws *WorkflowSchedule) GetBuyAndBook(wfID string, request *tools.APIRequest var m sync.Mutex for _, b := range bookings { - go getBooking(b, request, wf, execs, bookings, errCh, &m) + go getBooking(b, request, errCh, &m) } for i := 0; i < len(bookings); i++ { @@ -104,7 +104,7 @@ func (ws *WorkflowSchedule) GetBuyAndBook(wfID string, request *tools.APIRequest return true, wf, execs, purchased, bookings, nil } -func getBooking(b *booking.Booking, request *tools.APIRequest, wf *workflow.Workflow, execs []*WorkflowExecution, bookings []*booking.Booking, errCh chan error, m *sync.Mutex) { +func getBooking(b *booking.Booking, request *tools.APIRequest, errCh chan error, m *sync.Mutex) { m.Lock() c, err := getCallerCopy(request, errCh)