RTU get_operation_factory

Author: dandavison

temporalio/worker/_interceptor.py

@@ -313,7 +313,7 @@ def __post_init__(self) -> None:
             self._operation_name = self.operation
             self._input_type = None
         elif isinstance(self.operation, Callable):
-            _, op = nexusrpc.handler.get_operation_factory(self.operation)
+            _, op = nexusrpc.get_operation_factory(self.operation)
             if isinstance(op, nexusrpc.Operation):
                 self._operation_name = op.name
                 self._input_type = op.input_type

tests/nexus/test_dynamic_creation_of_user_handler_classes.py

@@ -3,8 +3,8 @@
 import httpx
 import nexusrpc.handler
 import pytest
+from nexusrpc import get_operation_factory
 from nexusrpc.handler import sync_operation
-from nexusrpc.handler._util import get_operation_factory
 
 from temporalio.client import Client
 from temporalio.worker import Worker

tests/nexus/test_handler_operation_definitions.py

@@ -92,7 +92,7 @@ async def test_collected_operation_names(
     assert isinstance(service_defn, nexusrpc.ServiceDefinition)
     assert service_defn.name == "Service"
     for method_name, expected_op in test_case.expected_operations.items():
-        _, actual_op = nexusrpc.handler.get_operation_factory(
+        _, actual_op = nexusrpc.get_operation_factory(
             getattr(test_case.Service, method_name)
         )
         assert isinstance(actual_op, nexusrpc.Operation)