Callback called when the Consumer blueprint is fully started.
(self, consumer)
| 79 | return super().start() |
| 80 | |
| 81 | def on_consumer_ready(self, consumer): |
| 82 | # type: (celery.worker.consumer.Consumer) -> None |
| 83 | """Callback called when the Consumer blueprint is fully started.""" |
| 84 | self._on_started.set() |
| 85 | test_worker_started.send( |
| 86 | sender=self.app, worker=self, consumer=consumer) |
| 87 | |
| 88 | def ensure_started(self): |
| 89 | # type: () -> None |