Cleanup

Author: dandavison

temporalio/worker/_nexus.py

@@ -225,10 +225,11 @@ async def _handle_start_operation_task(
                 start_response = await self._start_operation(start_request, headers)
             except BaseException as err:
                 logger.warning("Failed to execute Nexus start operation method")
-                handler_err = _exception_to_handler_error(err)
                 completion = temporalio.bridge.proto.nexus.NexusTaskCompletion(
                     task_token=task_token,
-                    error=await self._handler_error_to_proto(handler_err),
+                    error=await self._handler_error_to_proto(
+                        _exception_to_handler_error(err)
+                    ),
                 )
                 if isinstance(err, concurrent.futures.BrokenExecutor):
                     self._fail_worker_exception_queue.put_nowait(err)