diff --git a/models/workflow_execution/workflow_execution_mongo_accessor.go b/models/workflow_execution/workflow_execution_mongo_accessor.go index 732f8e9..473ae92 100755 --- a/models/workflow_execution/workflow_execution_mongo_accessor.go +++ b/models/workflow_execution/workflow_execution_mongo_accessor.go @@ -24,7 +24,7 @@ func newShallowAccessor(request *tools.APIRequest) *WorkflowExecutionMongoAccess Request: request, Type: tools.WORKFLOW_EXECUTION, New: func() *WorkflowExecution { return &WorkflowExecution{} }, - NotImplemented: []string{"DeleteOne", "StoreOne", "CopyOne"}, + NotImplemented: []string{"CopyOne"}, }, } } @@ -37,7 +37,7 @@ func NewAccessor(request *tools.APIRequest) *WorkflowExecutionMongoAccessor { Request: request, Type: tools.WORKFLOW_EXECUTION, New: func() *WorkflowExecution { return &WorkflowExecution{} }, - NotImplemented: []string{"DeleteOne", "StoreOne", "CopyOne"}, + NotImplemented: []string{"CopyOne"}, }, } } @@ -52,7 +52,7 @@ func (wfa *WorkflowExecutionMongoAccessor) UpdateOne(set map[string]interface{}, } func (a *WorkflowExecutionMongoAccessor) LoadOne(id string) (utils.DBObject, int, error) { - return utils.GenericLoadOne[*WorkflowExecution](id, a.New(), func(d utils.DBObject) (utils.DBObject, int, error) { + return utils.GenericLoadOne(id, a.New(), func(d utils.DBObject) (utils.DBObject, int, error) { now := time.Now() now = now.Add(time.Second * -60) if d.(*WorkflowExecution).State == enum.DRAFT && !a.shallow && now.UTC().After(d.(*WorkflowExecution).ExecDate) {