sdk-python: update v2 client and tests

Author: durable-workflow-ops

src/durable_workflow/client.py

@@ -266,15 +266,15 @@ async def signal_workflow(
     ) -> None:
         body: dict[str, Any] = {}
         if args:
-            body["input"] = args
+            body["input"] = serializer.envelope(args)
         await self._request("POST", f"/workflows/{workflow_id}/signal/{signal_name}", json=body, context=workflow_id)
 
     async def query_workflow(
         self, workflow_id: str, query_name: str, *, args: list[Any] | None = None
     ) -> Any:
         body: dict[str, Any] = {}
         if args:
-            body["input"] = args
+            body["input"] = serializer.envelope(args)
         return await self._request(
             "POST", f"/workflows/{workflow_id}/query/{query_name}", json=body, context=workflow_id
         )
@@ -303,7 +303,7 @@ async def update_workflow(
     ) -> Any:
         body: dict[str, Any] = {}
         if args:
-            body["input"] = args
+            body["input"] = serializer.envelope(args)
         if wait_for is not None:
             body["wait_for"] = wait_for
         if wait_timeout_seconds is not None:

tests/test_client.py

@@ -142,7 +142,8 @@ async def test_signal(self, client: Client) -> None:
             call_args = mock.call_args
             assert "/signal/my-signal" in call_args[0][1]
             body = call_args.kwargs.get("json") or call_args[1].get("json")
-            assert body["input"] == ["data"]
+            assert body["input"]["codec"] == "json"
+            assert json.loads(body["input"]["blob"]) == ["data"]
 
 
 class TestCancelWorkflow:
@@ -302,7 +303,8 @@ async def test_update(self, client: Client) -> None:
             call_args = mock.call_args
             assert "/update/my-update" in call_args[0][1]
             body = call_args.kwargs.get("json") or call_args[1].get("json")
-            assert body["input"] == ["data"]
+            assert body["input"]["codec"] == "json"
+            assert json.loads(body["input"]["blob"]) == ["data"]
             assert body["wait_for"] == "completed"
             assert body["wait_timeout_seconds"] == 10