def _handle_worker_exception(self, signum, frame):
with self._batch_lock:<EOL><INDENT>reraise(*self.exc_info)<EOL><DEDENT>
Handle an exception raised in the worker thread.

        Exceptions in the _batcher thread will send a SIGUSR1 to the main
        thread which we catch here, and then raise in the main thread.