(ctx context.Context)
| 310 | } |
| 311 | |
| 312 | func (s schedulerTaskSource) ActiveRuns(ctx context.Context) ([]taskpkg.Run, error) { |
| 313 | return s.store.ListTaskRunsByStatus(ctx, []taskpkg.RunStatus{ |
| 314 | taskpkg.TaskRunStatusClaimed, |
| 315 | taskpkg.TaskRunStatusStarting, |
| 316 | taskpkg.TaskRunStatusRunning, |
| 317 | }) |
| 318 | } |
| 319 | |
| 320 | func (s schedulerTaskSource) RecoverExpiredRunLeases( |
| 321 | ctx context.Context, |
nothing calls this directly
no test coverage detected