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

Method ListTaskRunsByStatus

internal/task/manager_test.go:1101–1116  ·  view source on GitHub ↗
(
	_ context.Context,
	statuses []RunStatus,
)

Source from the content-addressed store, hash-verified

1099}
1100
1101func (s *inMemoryManagerStore) ListTaskRunsByStatus(
1102 _ context.Context,
1103 statuses []RunStatus,
1104) ([]Run, error) {
1105 allowed := make(map[RunStatus]struct{}, len(statuses))
1106 for _, status := range statuses {
1107 allowed[status.Normalize()] = struct{}{}
1108 }
1109 runs := make([]Run, 0)
1110 for _, run := range s.runs {
1111 if _, ok := allowed[run.Status.Normalize()]; ok {
1112 runs = append(runs, cloneTaskRun(run))
1113 }
1114 }
1115 return runs, nil
1116}
1117
1118func (s *inMemoryManagerStore) GetTaskTriageState(
1119 _ context.Context,

Callers

nothing calls this directly

Calls 3

appendFunction · 0.85
cloneTaskRunFunction · 0.85
NormalizeMethod · 0.45

Tested by

no test coverage detected