( ctx context.Context, now time.Time, actor taskpkg.ActorContext, )
| 326 | } |
| 327 | |
| 328 | func (s schedulerTaskSource) ExpireTaskBlocks( |
| 329 | ctx context.Context, |
| 330 | now time.Time, |
| 331 | actor taskpkg.ActorContext, |
| 332 | ) (taskpkg.ExpireTaskBlocksResult, error) { |
| 333 | return s.manager.ExpireTaskBlocks(ctx, now, actor) |
| 334 | } |
| 335 | |
| 336 | func (s schedulerTaskSource) GetRunStatus( |
| 337 | ctx context.Context, |
nothing calls this directly
no test coverage detected