Method canonicalTaskStatusReadOnlyWithStore

internal/task/manager.go:2912–2958

(
	ctx context.Context,
	store DeleteTaskMutationStore,
	record Task,
	dependencies []Dependency,
	runs []Run,
	visited map[string]struct{},
)

}

func (m *Service) canonicalTaskStatusReadOnlyWithStore(
	ctx context.Context,
	store DeleteTaskMutationStore,
	record Task,
	dependencies []Dependency,
	runs []Run,
	visited map[string]struct{},
) (Status, error) {
	taskID := strings.TrimSpace(record.ID)
	if taskID != "" {
		if _, seen := visited[taskID]; seen {
			// Defensive termination guard: dependency cycles are invalid, but read
			// paths should still terminate without mutating persisted state.
			return taskStatusFromPolicySnapshot(
				record.Status,
				true,
				taskApprovalBlocked(record),
				taskPausedBlocked(record),
				false,
				taskNeedsAttentionBlocked(record),
				taskAttemptsExhausted(record, runs),
				runs,
			), nil
		}
		visited[taskID] = struct{}{}
		defer delete(visited, taskID)
	}

	unresolvedDependencies, err := m.hasUnresolvedDependenciesReadOnlyWithStore(ctx, store, dependencies, visited)
	if err != nil {
		return "", err
	}
	openBlocks, err := store.HasOpenTaskBlocks(ctx, record.ID)
	if err != nil {
		return "", err
	}
	return taskStatusFromPolicySnapshot(
		record.Status,
		unresolvedDependencies,
		taskApprovalBlocked(record),
		taskPausedBlocked(record),
		openBlocks,
		taskNeedsAttentionBlocked(record),
		taskAttemptsExhausted(record, runs),
		runs,
	), nil
}

func hasOpenRun(runs []Run) bool {
	for _, run := range runs {