fix: update run status

This commit is contained in:
Jason Song
2022-10-21 16:15:59 +08:00
parent 3d4d44dadf
commit d6e100f6be
3 changed files with 15 additions and 1 deletions

View File

@ -105,12 +105,20 @@ func UpdateRunJob(ctx context.Context, job *RunJob, cols ...string) error {
return nil
}
if job.RunID == 0 {
var err error
if job, err = GetRunJobByID(ctx, job.ID); err != nil {
return err
}
}
jobs, err := GetRunJobsByRunID(ctx, job.RunID)
if err != nil {
return err
}
runStatus := aggregateJobStatus(jobs)
run := &Run{
ID: job.RunID,
Status: runStatus,