diff --git a/execution/executors/shim/process.go b/execution/executors/shim/process.go index f659a57..b1045cc 100644 --- a/execution/executors/shim/process.go +++ b/execution/executors/shim/process.go @@ -35,6 +35,11 @@ func newProcess(ctx context.Context, o newProcessOpts) (*process, error) { if err != nil { return nil, err } + defer func() { + if err != nil { + o.container.StateDir().DeleteProcess(o.ID) + } + }() exitPipe, controlPipe, err := getControlPipes(procStateDir) if err != nil {