Skip to content

Commit 81ed22f

Browse files
committed
change function name
Signed-off-by: Min Min <[email protected]>
1 parent cb1eccc commit 81ed22f

File tree

1 file changed

+3
-3
lines changed
  • pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller

1 file changed

+3
-3
lines changed

pkg/microservice/aslan/core/common/service/workflowcontroller/jobcontroller/job.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -129,11 +129,11 @@ func runJob(ctx context.Context, job *commonmodels.JobTask, workflowCtx *commonm
129129
debug.PrintStack()
130130
job.Status = config.StatusFailed
131131
job.Error = errMsg
132-
setJobStatusContext(job, workflowCtx)
132+
setJobFinalStatusContext(job, workflowCtx)
133133
}
134134
job.EndTime = time.Now().Unix()
135135
logger.Infof("finish job: %s,status: %s", job.Name, job.Status)
136-
setJobStatusContext(job, workflowCtx)
136+
setJobFinalStatusContext(job, workflowCtx)
137137
ack()
138138
logger.Infof("updating job info into db...")
139139
err := jobCtl.SaveInfo(ctx)
@@ -447,7 +447,7 @@ func setJobStartTimeContext(job *commonmodels.JobTask, workflowCtx *commonmodels
447447

448448
// setJobStatusContext sets the global context variable for job status
449449
// Format: .job.<jobKey>.status
450-
func setJobStatusContext(job *commonmodels.JobTask, workflowCtx *commonmodels.WorkflowTaskCtx) {
450+
func setJobFinalStatusContext(job *commonmodels.JobTask, workflowCtx *commonmodels.WorkflowTaskCtx) {
451451
statusStr := string(job.Status)
452452
contextKey := fmt.Sprintf(".job.%s.status", job.Key)
453453
workflowCtx.GlobalContextSet(contextKey, statusStr)

0 commit comments

Comments
 (0)