Method loadRunWithTask

internal/task/manager.go:3303–3318

(ctx context.Context, runID string)

}

func (m *Service) loadRunWithTask(ctx context.Context, runID string) (Run, Task, error) {
	trimmedRunID := strings.TrimSpace(runID)
	if trimmedRunID == "" {
		return Run{}, Task{}, fmt.Errorf("%w: task run id is required", ErrValidation)
	}

	run, err := m.store.GetTaskRun(ctx, trimmedRunID)
	if err != nil {
		return Run{}, Task{}, err
	}
	taskRecord, err := m.store.GetTask(ctx, run.TaskID)
	if err != nil {
		return Run{}, Task{}, err
	}
	return run, taskRecord, nil
}

func (m *Service) ensureTaskExecutable(ctx context.Context, record Task) error {
	dependencies, err := m.store.ListDependencies(ctx, record.ID)