Function activeRunSummary

internal/task/manager.go:3980–4018

(runs []Run, maxAttempts int)

}

func activeRunSummary(runs []Run, maxAttempts int) *RunSummary {
	var current *Run
	for idx := range runs {
		run := runs[idx]
		if isTerminalRunStatus(run.Status) {
			continue
		}
		if current == nil || prefersActiveRun(run, *current) {
			candidate := run
			current = &candidate
		}
	}
	if current == nil {
		return nil
	}
	summary := &RunSummary{
		ID:                    current.ID,
		TaskID:                current.TaskID,
		Status:                current.Status,
		Attempt:               current.Attempt,
		PreviousRunID:         current.PreviousRunID,
		FailureKind:           current.FailureKind,
		MaxAttempts:           maxAttempts,
		SessionID:             current.SessionID,
		ClaimedBy:             cloneActorIdentity(current.ClaimedBy),
		ClaimTokenHash:        current.ClaimTokenHash,
		LeaseUntil:            current.LeaseUntil,
		HeartbeatAt:           current.HeartbeatAt,
		CoordinationChannelID: current.CoordinationChannelID,
		DesignationGroupID:    current.DesignationGroupID,
		QueuedAt:              current.QueuedAt,
		ClaimedAt:             current.ClaimedAt,
		StartedAt:             current.StartedAt,
		EndedAt:               current.EndedAt,
		Error:                 current.Error,
	}
	ApplyRunDesignationSummary(summary, *current)
	return summary
}

func prefersActiveRun(candidate Run, current Run) bool {
	candidateRank := activeRunRank(candidate.Status)