Make validator interceptor sync

Author: Sushisource

temporalio/worker/_interceptor.py

@@ -326,9 +326,9 @@ async def handle_query(self, input: HandleQueryInput) -> Any:
         """Called to handle a query."""
         return await self.next.handle_query(input)
 
-    async def handle_update_validator(self, input: HandleUpdateInput) -> None:
+    def handle_update_validator(self, input: HandleUpdateInput) -> None:
         """Called to handle an update's validation stage."""
-        return await self.next.handle_update_validator(input)
+        return self.next.handle_update_validator(input)
 
     async def handle_update_handler(self, input: HandleUpdateInput) -> Any:
         """Called to handle an update's handler."""

temporalio/worker/_workflow_instance.py

@@ -452,7 +452,7 @@ async def run_update() -> None:
 
                 # Always run the validator interceptor, which will only actually run a validator if one is defined.
                 with self._as_read_only():
-                    await self._inbound.handle_update_validator(handler_input)
+                    self._inbound.handle_update_validator(handler_input)
 
                 # Accept the update
                 command.update_response.accepted.SetInParent()
@@ -1788,7 +1788,7 @@ async def handle_query(self, input: HandleQueryInput) -> Any:
         else:
             return handler(*input.args)
 
-    async def handle_update_validator(self, input: HandleUpdateInput) -> None:
+    def handle_update_validator(self, input: HandleUpdateInput) -> None:
         # Do not "or None" the validator, since we only want to use the validator for
         # the specific named update - we shouldn't fall back to the dynamic validator
         # for some defined, named update which doesn't have a defined validator.

tests/worker/test_interceptor.py

@@ -80,9 +80,9 @@ async def handle_query(self, input: HandleQueryInput) -> Any:
         interceptor_traces.append(("workflow.query", input))
         return await super().handle_query(input)
 
-    async def handle_update_validator(self, input: HandleUpdateInput) -> None:
+    def handle_update_validator(self, input: HandleUpdateInput) -> None:
         interceptor_traces.append(("workflow.update.validator", input))
-        return await super().handle_update_validator(input)
+        return super().handle_update_validator(input)
 
     async def handle_update_handler(self, input: HandleUpdateInput) -> Any:
         interceptor_traces.append(("workflow.update.handler", input))