List of currently reserved tasks, not including scheduled/active.
(state, **kwargs)
| 426 | |
| 427 | @inspect_command(alias='dump_reserved') |
| 428 | def reserved(state, **kwargs): |
| 429 | """List of currently reserved tasks, not including scheduled/active.""" |
| 430 | reserved_tasks = ( |
| 431 | state.tset(worker_state.reserved_requests) - |
| 432 | state.tset(worker_state.active_requests) |
| 433 | ) |
| 434 | if not reserved_tasks: |
| 435 | return [] |
| 436 | return [request.info() for request in reserved_tasks] |
| 437 | |
| 438 | |
| 439 | @inspect_command(alias='dump_active') |