(self, task)
| 86 | ) |
| 87 | |
| 88 | def call_task(self, task): |
| 89 | try: |
| 90 | self.app.signature(task).apply_async() |
| 91 | except Exception as exc: # pylint: disable=broad-except |
| 92 | logger.exception('Could not call task: %r', exc) |
| 93 | |
| 94 | def on_elect(self, event): |
| 95 | try: |