Method mutateTaskTriage

internal/task/manager.go:1000–1041

(
	ctx context.Context,
	id string,
	actor ActorContext,
	mutate func(state *TriageState, latestActivity time.Time),
)

}

func (m *Service) mutateTaskTriage(
	ctx context.Context,
	id string,
	actor ActorContext,
	mutate func(state *TriageState, latestActivity time.Time),
) (TriageState, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return TriageState{}, err
	}

	trimmedID := strings.TrimSpace(id)
	if trimmedID == "" {
		return TriageState{}, fmt.Errorf("%w: task id is required", ErrValidation)
	}

	record, err := m.store.GetTask(ctx, trimmedID)
	if err != nil {
		return TriageState{}, err
	}
	runs, err := m.store.ListTaskRuns(ctx, RunQuery{TaskID: trimmedID})
	if err != nil {
		return TriageState{}, err
	}
	events, err := m.store.ListTaskEvents(ctx, EventQuery{TaskID: trimmedID, Limit: 1})
	if err != nil {
		return TriageState{}, err
	}

	state, err := m.loadTaskTriageState(ctx, trimmedID, actor.Actor)
	if err != nil {
		return TriageState{}, err
	}
	mutate(&state, latestTaskActivityAt(record, runs, events))
	state.TaskID = trimmedID
	state.Actor = actor.Actor
	state.UpdatedAt = m.now().UTC()
	if err := m.store.UpsertTaskTriageState(ctx, state); err != nil {
		return TriageState{}, err
	}

	return state, nil
}

func (m *Service) loadTaskTriageState(
	ctx context.Context,