( _ context.Context, statuses []RunStatus, )
| 1099 | } |
| 1100 | |
| 1101 | func (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 | |
| 1118 | func (s *inMemoryManagerStore) GetTaskTriageState( |
| 1119 | _ context.Context, |
nothing calls this directly
no test coverage detected