(self, pool, signal=None)
| 414 | return True |
| 415 | |
| 416 | def terminate(self, pool, signal=None): |
| 417 | signal = _signals.signum(signal or TERM_SIGNAME) |
| 418 | if self.time_start: |
| 419 | pool.terminate_job(self.worker_pid, signal) |
| 420 | self._announce_revoked('terminated', True, signal, False) |
| 421 | else: |
| 422 | self._terminate_on_ack = pool, signal |
| 423 | if self._apply_result is not None: |
| 424 | obj = self._apply_result() # is a weakref |
| 425 | if obj is not None: |
| 426 | obj.terminate(signal) |
| 427 | |
| 428 | def cancel(self, pool, signal=None, emit_retry=True): |
| 429 | signal = _signals.signum(signal or TERM_SIGNAME) |
no test coverage detected