fix: operations associated with incorrect ID when tasks are rescheduled

garethgeorge · Dec 26, 2023 · 25871c9 · 25871c9
1 parent adbe005
commit 25871c9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/orchestrator/tasks.go b/internal/orchestrator/tasks.go
@@ -54,6 +54,9 @@ func (t *TaskWithOperation) runWithOpAndContext(ctx context.Context, do func(ctx
 
 	t.running.Store(true)
 	defer t.running.Store(false)
+	defer func() {
+		t.op = nil
+	}()
 
 	return WithOperation(t.orch.OpLog, t.op, func() error {
 		return do(ctx, t.op)