|
|
|
@ -194,9 +194,13 @@ func (m *model) updateWorkflow(wf *jw.Workflow, job *jw.Job) error {
|
|
|
|
|
return err |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// AFINIR: statut du workflow
|
|
|
|
|
if stepName == "" { |
|
|
|
|
wf.Status = jw.StatusSucceeded |
|
|
|
|
if job.ErrorCounter > 0 { |
|
|
|
|
wf.Status = jw.StatusFailed |
|
|
|
|
} else { |
|
|
|
|
wf.Status = jw.StatusSucceeded |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
wf.Finished() |
|
|
|
|
|
|
|
|
|
return m.storageUpdateWorkflow(wf, job, nil) |
|
|
|
|