Method ensureTaskExecutable

internal/task/manager.go:3320–3344

(ctx context.Context, record Task)

}

func (m *Service) ensureTaskExecutable(ctx context.Context, record Task) error {
	dependencies, err := m.store.ListDependencies(ctx, record.ID)
	if err != nil {
		return err
	}
	runs, err := m.store.ListTaskRuns(ctx, RunQuery{TaskID: record.ID})
	if err != nil {
		return err
	}
	status, err := m.canonicalTaskStatus(ctx, record, dependencies, runs)
	if err != nil {
		return err
	}

	switch status.Normalize() {
	case TaskStatusBlocked:
		return fmt.Errorf("%w: task %q is blocked", ErrInvalidStatusTransition, record.ID)
	case TaskStatusDraft:
		return fmt.Errorf("%w: task %q is draft", ErrInvalidStatusTransition, record.ID)
	case TaskStatusCanceled:
		return fmt.Errorf("%w: task %q is canceled", ErrInvalidStatusTransition, record.ID)
	default:
		return nil
	}
}

func (m *Service) requireSessionExecutor(action string) error {
	if m.sessions == nil {