(self, producer, task_id)
| 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') |
no outgoing calls