List of tasks currently being executed.
(state, safe=False, **kwargs)
| 438 | |
| 439 | @inspect_command(alias='dump_active') |
| 440 | def active(state, safe=False, **kwargs): |
| 441 | """List of tasks currently being executed.""" |
| 442 | return [request.info(safe=safe) |
| 443 | for request in state.tset(worker_state.active_requests)] |
| 444 | |
| 445 | |
| 446 | @inspect_command(alias='dump_revoked') |