(self)
| 33 | self._stop_at_last = stop_at_last |
| 34 | |
| 35 | def _before_train(self): |
| 36 | logger.info("Starting " + |
| 37 | ', '.join([k.name for k in self._procs_threads]) + ' ...') |
| 38 | # avoid sigint get handled by other processes |
| 39 | start_proc_mask_signal(self._procs_threads) |
| 40 | |
| 41 | def _after_train(self): |
| 42 | if not self._stop_at_last: |
nothing calls this directly
no test coverage detected