Wait for worker to be fully up and running. Warning: Worker must be started within a thread for this to work, or it will block forever.
(self)
| 86 | sender=self.app, worker=self, consumer=consumer) |
| 87 | |
| 88 | def ensure_started(self): |
| 89 | # type: () -> None |
| 90 | """Wait for worker to be fully up and running. |
| 91 | |
| 92 | Warning: |
| 93 | Worker must be started within a thread for this to work, |
| 94 | or it will block forever. |
| 95 | """ |
| 96 | self._on_started.wait() |
| 97 | |
| 98 | |
| 99 | @contextmanager |