code: func (engine *DockerTaskEngine) openEventstream(ctx context.Context) error {
  	events, err := engine.client.ContainerEvents(ctx)
  	if err != nil {
  		return err
  	}
  	engine.events = events
  	return nil
  }
docs: // openEventstream opens, but does not consume, the docker event stream