Skip to content
This repository was archived by the owner on Feb 7, 2025. It is now read-only.

Commit 0a348c8

Browse files
committed
fix: task queue misaligned issue
1 parent 8b7ee05 commit 0a348c8

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

task/handler/service.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,12 @@ func (svc *Service) Fetch() {
111111
// run task
112112
if err := svc.run(tid); err != nil {
113113
trace.PrintError(err)
114+
t, err := svc.GetTaskById(tid)
115+
if err == nil {
116+
t.SetError(err.Error())
117+
_ = svc.SaveTask(t, constants.TaskStatusError)
118+
continue
119+
}
114120
continue
115121
}
116122
}
@@ -360,7 +366,7 @@ func (svc *Service) run(taskId primitive.ObjectID) (err error) {
360366
// create a new task runner
361367
r, err := NewTaskRunner(taskId, svc)
362368
if err != nil {
363-
return err
369+
return trace.TraceError(err)
364370
}
365371

366372
// add runner to pool

0 commit comments

Comments
 (0)