def _handle_abort(self, signum, frame):
    self.logger.debug('Signal handler called for signal {} from {}'.format(signum, threading.current_thread()))
    if self._pool:
        self._pool.abort()
        os.kill(os.getpid(), 9)
        self.logger.debug('Pool {} aborted.'.format(self._pool))
def _handle_abort(self, signum, frame):
    self.logger.debug('Signal handler called for signal {} from {}'.format(signum, threading.current_thread()))
    if self._pool:
        self._pool.abort()
        os.kill(os.getpid(), 9)
        self.logger.debug('Pool {} aborted.'.format(self._pool))