(self)
| 118 | self.pending_shutdown = True |
| 119 | |
| 120 | def check_status(self) -> bool: |
| 121 | logger.debug(f"Checking status of {self.name}") |
| 122 | if self.exc: |
| 123 | traceback.print_tb(self.exc.__traceback__) |
| 124 | logger.error(f"Caught exception: {self.exc.__class__.__name__}") |
| 125 | raise self.exc |
| 126 | if not self.is_alive(): |
| 127 | logger.warning(f"{self.name} not alive") |
| 128 | self.start() |
| 129 | return True |
| 130 | |
| 131 | def main(self) -> None: |
| 132 | raise NotImplementedError() |