Merge pull request #3253 from corhere/c8dexecutor-task-delete

containerdexecutor: clean up task if Start() fails
moby · Nov 3, 2022 · 60c9d2c · 60c9d2c
2 parents 14fa4f2 + f448313
commit 60c9d2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/executor/containerdexecutor/executor.go b/executor/containerdexecutor/executor.go
@@ -205,7 +205,7 @@ func (w *containerdExecutor) Run(ctx context.Context, id string, root executor.M
 	}
 
 	defer func() {
-		if _, err1 := task.Delete(context.TODO()); err == nil && err1 != nil {
+		if _, err1 := task.Delete(context.TODO(), containerd.WithProcessKill); err == nil && err1 != nil {
 			err = errors.Wrapf(err1, "failed to delete task %s", id)
 		}
 	}()