Method runWaitExec

pkg/compose/hook.go:99–127

(ctx context.Context, execID string, service types.ServiceConfig, listener api.ContainerEventListener)

}

func (s *composeService) runWaitExec(ctx context.Context, execID string, service types.ServiceConfig, listener api.ContainerEventListener) error {
	_, err := s.apiClient().ExecStart(ctx, execID, client.ExecStartOptions{
		Detach: listener == nil,
		TTY:    service.Tty,
	})
	if err != nil {
		return err
	}

	// We miss a ContainerExecWait API
	tick := time.NewTicker(100 * time.Millisecond)
	for {
		select {
		case <-ctx.Done():
			return nil
		case <-tick.C:
			inspect, err := s.apiClient().ExecInspect(ctx, execID, client.ExecInspectOptions{})
			if err != nil {
				return nil
			}
			if !inspect.Running {
				if inspect.ExitCode != 0 {
					return fmt.Errorf("%s hook exited with status %d", service.Name, inspect.ExitCode)
				}
				return nil
			}
		}
	}
}