(self)
| 1021 | coro.close() |
| 1022 | |
| 1023 | async def _shutdown_graceful_reactorless(self) -> None: |
| 1024 | await self.stop() |
| 1025 | if not self._stop_after_crawl: |
| 1026 | # wait until crawl tasks finish and cancel the future |
| 1027 | await self.join() |
| 1028 | if self._reactorless_main_task and not self._reactorless_main_task.done(): |
| 1029 | self._reactorless_main_task.cancel() |
| 1030 | |
| 1031 | def _signal_kill_reactorless(self, signum: int, _: Any) -> None: |
| 1032 | install_shutdown_handlers(signal.SIG_IGN) |
no test coverage detected