(self)
| 161 | predictors, batch_size=PREDICT_BATCH_SIZE) |
| 162 | |
| 163 | def _before_train(self): |
| 164 | self.async_predictor.start() |
| 165 | logger.info("Starting MySimulatorMaster ...") |
| 166 | start_proc_mask_signal(self) |
| 167 | |
| 168 | def _on_state(self, state, client): |
| 169 | """ |
nothing calls this directly
no test coverage detected