(self)
| 303 | self._failed_cnt.acquire() |
| 304 | |
| 305 | def _cleanup_child(self): |
| 306 | if callable(self.finish_callback): |
| 307 | # noinspection PyBroadException |
| 308 | try: |
| 309 | self.finish_callback() |
| 310 | except: |
| 311 | traceback.print_exc() |
| 312 | self._busy_lock_dec() |
| 313 | try: |
| 314 | # TODO: try-except should not be necessary here. There seems to be a bug when using map with direct=False |
| 315 | self._children.remove(current_thread()) |
| 316 | except ValueError: |
| 317 | pass |
| 318 | |
| 319 | def _append_failed(self, jobid, exc, args, kwargs): |
| 320 | if self.result_id: |
no test coverage detected