(self)
| 93 | loop.add_signal_handler(signal.SIGQUIT, self.handle_exit, signal.SIGQUIT, None) |
| 94 | |
| 95 | async def _serve(self) -> None: |
| 96 | self.config.app = self.wsgi |
| 97 | server = Server(config=self.config) |
| 98 | self._install_sigquit_handler() |
| 99 | await server.serve(sockets=self.sockets) |
| 100 | if not server.started: |
| 101 | sys.exit(Arbiter.WORKER_BOOT_ERROR) |
| 102 | |
| 103 | def run(self) -> None: |
| 104 | return asyncio_run(self._serve(), loop_factory=self.config.get_loop_factory()) |
no test coverage detected