Method handleWait

driver/driver.go:687–698

(ctx context.Context, handle *taskHandle, ch chan *drivers.ExitResult)

}

func (d *Driver) handleWait(ctx context.Context, handle *taskHandle, ch chan *drivers.ExitResult) {
	defer close(ch)

	select {
	case <-ctx.Done():
		return
	case <-d.ctx.Done():
		return
	case <-handle.ctx.Done():
		ch <- handle.GetExitResult()
	}
}

// StopTask will not be called if the task has already exited (e.g. onError).
func (d *Driver) StopTask(taskID string, timeout time.Duration, signal string) error {