diff --git a/drivers/docker/driver.go b/drivers/docker/driver.go index 4242db4aa80c..20b27626b90c 100644 --- a/drivers/docker/driver.go +++ b/drivers/docker/driver.go @@ -1323,7 +1323,7 @@ func (d *Driver) ExecTaskStreaming(ctx context.Context, taskID string, opts *dri const execTerminatingTimeout = 3 * time.Second start := time.Now() var res *docker.ExecInspect - for res == nil || res.Running || time.Since(start) > execTerminatingTimeout { + for (res == nil || res.Running) && time.Since(start) <= execTerminatingTimeout { res, err = client.InspectExec(exec.ID) if err != nil { return nil, fmt.Errorf("failed to inspect exec result: %v", err)