MCPcopy Create free account
hub / github.com/compozy/agh / taskRunPolicyState

Function taskRunPolicyState

internal/task/manager.go:3042–3059  ·  view source on GitHub ↗
(runs []Run)

Source from the content-addressed store, hash-verified

3040}
3041
3042func taskRunPolicyState(runs []Run) taskRunPolicySnapshot {
3043 state := taskRunPolicySnapshot{}
3044 for idx := range runs {
3045 run := runs[idx]
3046 switch run.Status.Normalize() {
3047 case TaskRunStatusStarting, TaskRunStatusRunning:
3048 state.hasActive = true
3049 case TaskRunStatusQueued, TaskRunStatusClaimed:
3050 state.hasQueuedOrClaimed = true
3051 case TaskRunStatusCompleted, TaskRunStatusFailed, TaskRunStatusCanceled:
3052 if !state.hasLatestTerminal || runComesAfter(run, state.latestTerminal) {
3053 state.latestTerminal = run
3054 state.hasLatestTerminal = true
3055 }
3056 }
3057 }
3058 return state
3059}
3060
3061func taskStatusFromTerminalRun(run Run, attemptsExhausted bool) (Status, bool) {
3062 switch run.Status.Normalize() {

Callers 1

Calls 2

runComesAfterFunction · 0.85
NormalizeMethod · 0.45

Tested by

no test coverage detected