updated with riku's code
This commit is contained in:
parent
6bdaa811d6
commit
2d7ad48994
@ -107,12 +107,13 @@ func dockerRun(cfg *container.Config, sess ssh.Session) (status int64, cleanup f
|
||||
}
|
||||
}()
|
||||
}
|
||||
statusChan, chanErr := docker.ContainerWait(ctx, res.ID, container.WaitConditionNotRunning)
|
||||
if chanErr != nil {
|
||||
return
|
||||
}
|
||||
err = <-chanErr
|
||||
s := <-statusChan
|
||||
status = s.StatusCode
|
||||
resultC, errC := docker.ContainerWait(ctx, res.ID, container.WaitConditionNotRunning)
|
||||
select {
|
||||
case err = <-errC:
|
||||
return
|
||||
case result := <-resultC:
|
||||
status = result.StatusCode
|
||||
}
|
||||
err = <-outputErr
|
||||
return
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user