(self)
| 274 | result.abort() |
| 275 | |
| 276 | def pre_shutdown(self): |
| 277 | if not self.workers_started: |
| 278 | return |
| 279 | logger_debug('Proxy.pre_shutdown...\n', "yellow") |
| 280 | |
| 281 | if self.doing_shutdown: |
| 282 | return |
| 283 | else: |
| 284 | self.doing_shutdown = True |
| 285 | |
| 286 | self._abort_all_requests() |
| 287 | |
| 288 | # notify the workers to quit |
| 289 | if all(not f.done() for f in self.mpi_futures): |
| 290 | self.request_queue.put_noblock(None, retry=4) |
| 291 | |
| 292 | def shutdown(self): |
| 293 | if not self.workers_started: |
no test coverage detected