diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 4d24e07..1fb3e0b 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -51,7 +51,7 @@ func (wfa *workflowMongoAccessor) execution(realData *Workflow, delete bool) (in obj := &workflow_execution.WorkflowExecution{ ExecDate: &s, EndDate: realData.Schedule.End, - State: workflow_execution.SCHEDULED, + State: workflow_execution.SCHEDULED.EnumIndex(), WorkflowID: realData.UUID, } accessor.StoreOne(obj) @@ -61,7 +61,7 @@ func (wfa *workflowMongoAccessor) execution(realData *Workflow, delete bool) (in obj := &workflow_execution.WorkflowExecution{ ExecDate: realData.Schedule.Start, EndDate: realData.Schedule.End, - State: workflow_execution.SCHEDULED, + State: workflow_execution.SCHEDULED.EnumIndex(), WorkflowID: realData.UUID, } accessor.StoreOne(obj) diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go index ebf01cf..a813e06 100644 --- a/models/workflow_execution/workflow_execution.go +++ b/models/workflow_execution/workflow_execution.go @@ -38,11 +38,11 @@ func (d ScheduledType) EnumIndex() int { } type WorkflowExecution struct { - UUID string `json:"id,omitempty" bson:"id,omitempty" validate:"required"` - ExecDate *time.Time `json:"execution_date,omitempty" bson:"execution_date,omitempty" validate:"required"` - EndDate *time.Time `json:"end_date,omitempty" bson:"end_date,omitempty"` - State ScheduledType `json:"state,omitempty" bson:"state,omitempty" ` - WorkflowID string `json:"workflow_id" bson:"workflow_id,omitempty"` + UUID string `json:"id,omitempty" bson:"id,omitempty" validate:"required"` + ExecDate *time.Time `json:"execution_date,omitempty" bson:"execution_date,omitempty" validate:"required"` + EndDate *time.Time `json:"end_date,omitempty" bson:"end_date,omitempty"` + State int `json:"state,omitempty" bson:"state,omitempty" ` + WorkflowID string `json:"workflow_id" bson:"workflow_id,omitempty"` } func (ao *WorkflowExecution) GetID() string {