Return list of tasks currently executed by workers. Arguments: safe (Boolean): Set to True to disable deserialization. Returns: Dict: Dictionary ``{HOSTNAME: [TASK_INFO,...]}``. See Also: For ``TASK_INFO`` details see :func:`query_task`
(self, safe=None)
| 134 | return self._request('clock') |
| 135 | |
| 136 | def active(self, safe=None): |
| 137 | """Return list of tasks currently executed by workers. |
| 138 | |
| 139 | Arguments: |
| 140 | safe (Boolean): Set to True to disable deserialization. |
| 141 | |
| 142 | Returns: |
| 143 | Dict: Dictionary ``{HOSTNAME: [TASK_INFO,...]}``. |
| 144 | |
| 145 | See Also: |
| 146 | For ``TASK_INFO`` details see :func:`query_task` return value. |
| 147 | |
| 148 | """ |
| 149 | return self._request('active', safe=safe) |
| 150 | |
| 151 | def scheduled(self, safe=None): |
| 152 | """Return list of scheduled tasks with details. |