MCPcopy
hub / github.com/celery/celery / drain_events

Method drain_events

celery/backends/asynchronous.py:369–370  ·  view source on GitHub ↗
(self, timeout=None)

Source from the content-addressed store, hash-verified

367 pass
368
369 def drain_events(self, timeout=None):
370 raise NotImplementedError()
371
372 def consume_from(self, task_id):
373 raise NotImplementedError()

Callers 1

runMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected