Return list of revoked tasks. >>> app.control.inspect().revoked() {'celery@node1': ['16f527de-1c72-47a6-b477-c472b92fef7a']} Returns: Dict: Dictionary ``{HOSTNAME: [TASK_ID, ...]}``.
(self)
| 243 | return self._request('stats') |
| 244 | |
| 245 | def revoked(self): |
| 246 | """Return list of revoked tasks. |
| 247 | |
| 248 | >>> app.control.inspect().revoked() |
| 249 | {'celery@node1': ['16f527de-1c72-47a6-b477-c472b92fef7a']} |
| 250 | |
| 251 | Returns: |
| 252 | Dict: Dictionary ``{HOSTNAME: [TASK_ID, ...]}``. |
| 253 | """ |
| 254 | return self._request('revoked') |
| 255 | |
| 256 | def registered(self, *taskinfoitems): |
| 257 | """Return all registered tasks per worker. |