init error handler
(self, error_queue)
| 81 | the tracebacks to the parent process.""" |
| 82 | |
| 83 | def __init__(self, error_queue): |
| 84 | """ init error handler """ |
| 85 | import signal |
| 86 | import threading |
| 87 | self.error_queue = error_queue |
| 88 | self.children_pids = [] |
| 89 | self.error_thread = threading.Thread( |
| 90 | target=self.error_listener, daemon=True) |
| 91 | self.error_thread.start() |
| 92 | signal.signal(signal.SIGUSR1, self.signal_handler) |
| 93 | |
| 94 | def add_child(self, pid): |
| 95 | """ error handler """ |