Method inspectTaskRecord

internal/task/inspect.go:53–127

(
	ctx context.Context,
	taskRecord Task,
	target InspectTarget,
	focusedRunID string,
)

}

func (m *Service) inspectTaskRecord(
	ctx context.Context,
	taskRecord Task,
	target InspectTarget,
	focusedRunID string,
) (*InspectView, error) {
	asOf := m.now().UTC()
	childCount, err := m.store.CountDirectChildren(ctx, taskRecord.ID)
	if err != nil {
		return nil, err
	}
	dependencies, err := m.store.ListDependencies(ctx, taskRecord.ID)
	if err != nil {
		return nil, err
	}
	runs, err := m.store.ListTaskRuns(ctx, RunQuery{TaskID: taskRecord.ID})
	if err != nil {
		return nil, err
	}
	events, err := m.store.ListTaskEvents(ctx, EventQuery{TaskID: taskRecord.ID, Limit: 1})
	if err != nil {
		return nil, err
	}

	summary, err := m.enrichTaskSummaryFromState(ctx, taskRecord, childCount, dependencies, runs, events)
	if err != nil {
		return nil, err
	}

	currentRun := inspectCurrentRun(runs, taskRecord.CurrentRunID, focusedRunID)
	currentRunSummary := inspectRunSummaryPtr(currentRun, asOf)
	recentRuns := inspectRecentRuns(runs, asOf)
	boundSession, sessionCatalogPresent, eligibleSessionCount, err := m.inspectSessionState(
		ctx,
		taskRecord,
		currentRunSummary,
	)
	if err != nil {
		return nil, err
	}
	scheduler, err := m.inspectSchedulerState(ctx)
	if err != nil {
		return nil, err
	}
	recentEvents, err := m.inspectRecentEvents(ctx, taskRecord.ID, focusedRunID)
	if err != nil {
		return nil, err
	}

	view := &InspectView{
		Target:                target,
		Task:                  summary,
		CurrentRun:            currentRunSummary,
		BoundSession:          boundSession,
		RecentRuns:            recentRuns,
		RecentEvents:          recentEvents,
		Scheduler:             scheduler,
		AsOf:                  asOf,