Stop engine loop.
(self)
| 416 | return self.collective_rpc('get_input_processor', receiver_mask=1, return_mask=1)[0] |
| 417 | |
| 418 | def stop(self): |
| 419 | """Stop engine loop.""" |
| 420 | if self._prefetch_task is not None: |
| 421 | self._prefetch_task.cancel() |
| 422 | |
| 423 | def release(self): |
| 424 | """release.""" |
no test coverage detected