(self, e)
| 268 | self._worker_fun(self._worker_id) |
| 269 | |
| 270 | def handle_exception(self, e): |
| 271 | traceback.print_exc() |
| 272 | logging.exception("Exception in worker", e) |
| 273 | self._coordinator._stop("Exception in worker {}: {}".format( |
| 274 | self._worker_id, e |
| 275 | )) |
| 276 | |
| 277 | def finish(self): |
| 278 | self._metrics.put_metric( |
no test coverage detected