in internal/dal/workflow.go [313:333]
func (w *workflowDALImpl) buildTask(workflow *pmodel.Workflow) []*model.WorkflowTask {
if workflow == nil || len(workflow.States) == 0 {
return nil
}
var tasks []*model.WorkflowTask
for _, state := range workflow.States {
var task = model.WorkflowTask{}
task.WorkflowID = workflow.ID
task.TaskID = uuid.New().String()
task.TaskName = state.GetName()
task.Status = constants.NormalStatus
task.TaskType = gconv.String(state.GetType())
task.CreateTime = time.Now()
task.UpdateTime = time.Now()
task.Actions = w.buildTaskAction(task.TaskID, workflow, state)
w.fillTaskFilterIfExist(state, &task)
tasks = append(tasks, &task)
}
return tasks
}