Stop the process pool
(self)
| 475 | logger.info(f"Started process pool with {self.num_workers} processes") |
| 476 | |
| 477 | def stop(self) -> None: |
| 478 | """Stop the process pool""" |
| 479 | self.shutdown_event.set() |
| 480 | |
| 481 | if self.executor: |
| 482 | self.executor.shutdown(wait=True) |
| 483 | self.executor = None |
| 484 | |
| 485 | logger.info("Stopped process pool") |
| 486 | |
| 487 | def request_shutdown(self) -> None: |
| 488 | """Request graceful shutdown""" |