| 758 | |
| 759 | |
| 760 | class ManagerWatchdog(object): |
| 761 | def __init__(self): |
| 762 | self.manager_pid = os.getppid() |
| 763 | self.manager_dead = False |
| 764 | |
| 765 | def is_alive(self): |
| 766 | if not self.manager_dead: |
| 767 | self.manager_dead = os.getppid() != self.manager_pid |
| 768 | return not self.manager_dead |
| 769 | |
| 770 | |
| 771 | def stream_fetcher( |