Respond to upstream: nexusrpc.asyncio imports

Author: dandavison

temporalio/worker/_nexus.py

@@ -18,7 +18,9 @@
 
 import google.protobuf.json_format
 import nexusrpc.handler
-from nexusrpc.handler._core import SyncExecutor
+from nexusrpc.asyncio import LazyValue
+from nexusrpc.asyncio.handler import Handler
+from nexusrpc.handler import SyncExecutor
 
 import temporalio.api.common.v1
 import temporalio.api.enums.v1
@@ -64,7 +66,7 @@ def __init__(
                     f"Expected a service instance, but got a class: {service}. "
                     "Nexus services must be passed as instances, not classes."
                 )
-        self._handler = nexusrpc.handler.Handler(
+        self._handler = Handler(
             nexus_services,
             SyncExecutor(executor) if executor is not None else None,
         )
@@ -275,7 +277,7 @@ async def _start_operation(
         temporalio.nexus.current_context.set(
             temporalio.nexus.Context(operation_context=ctx)
         )
-        input = nexusrpc.handler.LazyValue(
+        input = LazyValue(
             serializer=_DummyPayloadSerializer(
                 data_converter=self._data_converter,
                 payload=start_request.payload,