MCPcopy
hub / github.com/celery/celery / revoked

Method revoked

celery/app/control.py:245–254  ·  view source on GitHub ↗

Return list of revoked tasks. >>> app.control.inspect().revoked() {'celery@node1': ['16f527de-1c72-47a6-b477-c472b92fef7a']} Returns: Dict: Dictionary ``{HOSTNAME: [TASK_ID, ...]}``.

(self)

Source from the content-addressed store, hash-verified

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.

Callers 8

test_revokedMethod · 0.45
test_already_revokedMethod · 0.45
test_revokedMethod · 0.45
test_revokedMethod · 0.45

Calls 1

_requestMethod · 0.95

Tested by 8

test_revokedMethod · 0.36
test_already_revokedMethod · 0.36
test_revokedMethod · 0.36
test_revokedMethod · 0.36