diff --git a/drivers/docker/handle.go b/drivers/docker/handle.go index 4f144a14d..968fe393a 100644 --- a/drivers/docker/handle.go +++ b/drivers/docker/handle.go @@ -105,17 +105,11 @@ func (h *taskHandle) Exec(ctx context.Context, cmd string, args []string) (*driv Detach: false, Tty: false, } - if err := h.dockerClient.ContainerExecStart(ctx, exec.ID, startOpts); err != nil { - return nil, err - } // hijack exec output streams - hijacked, err := h.dockerClient.ContainerExecAttach(ctx, exec.ID, containerapi.ExecStartOptions{ - Detach: false, - Tty: false, - }) + hijacked, err := h.dockerClient.ContainerExecAttach(ctx, exec.ID, startOpts) if err != nil { - return nil, fmt.Errorf("failed to attach to exec: %v", err) + return nil, fmt.Errorf("failed to attach to exec object: %w", err) } _, err = stdcopy.StdCopy(stdout, stderr, hijacked.Reader) @@ -128,7 +122,7 @@ func (h *taskHandle) Exec(ctx context.Context, cmd string, args []string) (*driv execResult.Stderr = stderr.Bytes() res, err := h.dockerClient.ContainerExecInspect(ctx, exec.ID) if err != nil { - return execResult, err + return execResult, fmt.Errorf("failed to inspect exit code of exec object: %w", err) } execResult.ExitResult.ExitCode = res.ExitCode diff --git a/e2e/consul/input/on_update_check_restart.nomad b/e2e/consul/input/on_update_check_restart.nomad index a8eadfb92..3aa22e328 100644 --- a/e2e/consul/input/on_update_check_restart.nomad +++ b/e2e/consul/input/on_update_check_restart.nomad @@ -48,7 +48,6 @@ job "test" { on_update = "ignore_warnings" args = [ - "-c", "/local/ready.sh" ] @@ -95,4 +94,3 @@ EOT } } } -