diff --git a/internal/uploads/worker.go b/internal/uploads/worker.go index 334efd3..e414e44 100644 --- a/internal/uploads/worker.go +++ b/internal/uploads/worker.go @@ -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. abort := func() { if ctx.Err() == nil { - tr.Fail() + tr.FailRunning() } w.fail(ctx, job, log) }