#382: align polyglot integration with avro default

Author: durable-workflow-ops

tests/integration/polyglot_fixtures.py

@@ -4,7 +4,7 @@
 These fixtures test bidirectional PHP↔Python worker interop:
 - Python activities called from PHP workflows
 - PHP activities called from Python workflows
-- JSON payload round-trip across runtimes
+- Avro payload round-trip across runtimes
 """
 from __future__ import annotations
 
@@ -17,7 +17,7 @@ async def polyglot_python_activity(input_data: dict) -> dict:
     Python activity fixture for polyglot interop testing.
 
     Accepts structured input from a PHP workflow and returns
-    enriched output to validate JSON codec round-trip.
+    enriched output to validate codec-aware round-trip behavior.
     """
     return {
         "runtime": "python",
@@ -45,7 +45,7 @@ class PolyglotPythonWorkflow:
 
     Schedules a PHP activity to validate that:
     1. Python workflows can call PHP activities
-    2. JSON payloads round-trip correctly across runtimes
+    2. Avro payloads round-trip correctly across runtimes
     3. Activity results from PHP are decoded properly in Python
     """
 

tests/integration/test_polyglot.py

@@ -30,7 +30,7 @@ async def test_python_workflow_calls_php_activity(server_url: str, server_token:
 
     This validates:
     - Python workflows can schedule activities with type keys registered by PHP workers
-    - JSON payloads serialize correctly from Python
+    - Avro payloads serialize correctly from Python by default
     - PHP activity results deserialize correctly in Python
     - Codec envelopes round-trip across runtimes
     """
@@ -44,7 +44,7 @@ async def test_python_workflow_calls_php_activity(server_url: str, server_token:
         "count": 42,
         "price": 99.95,
         "active": True,
-        "tags": ["python", "php", "json"],
+        "tags": ["python", "php", "avro"],
         "metadata": {
             "source": "integration-test",
             "version": 2,
@@ -96,7 +96,7 @@ async def test_python_workflow_calls_php_activity(server_url: str, server_token:
         # Verify activity arguments are envelope-wrapped
         activity_args = server_cmd.get("arguments", {})
         assert "codec" in activity_args, "activity arguments should be codec-wrapped"
-        assert activity_args.get("codec") == "json"
+        assert activity_args.get("codec") == "avro"
 
         # 5. Complete workflow task
         await client.complete_workflow_task(