File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -104,6 +104,7 @@ func (s *composeService) Logs(
104104 }
105105 })
106106 eg .Go (func () error {
107+ // pass ctx so monitor will immediately stop on SIGINT
107108 return monitor .Start (ctx )
108109 })
109110 }
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ func (c *monitor) Start(ctx context.Context) error {
7979 }
8080 restarting := utils.Set [string ]{}
8181
82- evtCh , errCh := c .api .Events (context . Background () , events.ListOptions {
82+ evtCh , errCh := c .api .Events (ctx , events.ListOptions {
8383 Filters : filters .NewArgs (
8484 filters .Arg ("type" , "container" ),
8585 projectFilter (c .project )),
@@ -89,6 +89,8 @@ func (c *monitor) Start(ctx context.Context) error {
8989 return nil
9090 }
9191 select {
92+ case <- ctx .Done ():
93+ return nil
9294 case err := <- errCh :
9395 return err
9496 case event := <- evtCh :
You can’t perform that action at this time.
0 commit comments