MCPcopy
hub / github.com/celery/celery / on_task_call

Method on_task_call

celery/backends/base.py:788–789  ·  view source on GitHub ↗
(self, producer, task_id)

Source from the content-addressed store, hash-verified

786 """Cleanup actions to do at the end of a task worker process."""
787
788 def on_task_call(self, producer, task_id):
789 return {}
790
791 def add_to_chord(self, chord_id, result):
792 raise NotImplementedError('Backend does not support add_to_chord')

Callers 3

test_on_task_callMethod · 0.45
electionMethod · 0.45
send_taskMethod · 0.45

Calls

no outgoing calls

Tested by 1

test_on_task_callMethod · 0.36