refactor(uploads): the worker's own failure is FailRunning
Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
@@ -219,7 +219,7 @@ func (w *Worker) Process(ctx context.Context, job Job) {
|
|||||||
// a failure: the row is left for the start-up sweep, so the step stays as it was.
|
// a failure: the row is left for the start-up sweep, so the step stays as it was.
|
||||||
abort := func() {
|
abort := func() {
|
||||||
if ctx.Err() == nil {
|
if ctx.Err() == nil {
|
||||||
tr.Fail()
|
tr.FailRunning()
|
||||||
}
|
}
|
||||||
w.fail(ctx, job, log)
|
w.fail(ctx, job, log)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user