Main entry point for the worker.
(self)
| 150 | sys.exit(1) |
| 151 | |
| 152 | def run(self): |
| 153 | """Main entry point for the worker.""" |
| 154 | try: |
| 155 | self.loop.run_until_complete(self._serve()) |
| 156 | except Exception as e: |
| 157 | self.log.exception("Worker exception: %s", e) |
| 158 | finally: |
| 159 | self._cleanup() |
| 160 | |
| 161 | async def _serve(self): |
| 162 | """Main async serving loop.""" |