Add PHP version marker replay fixture

Issue: zorporation/durable-workflow#495

Loop-ID: build-01

Author: durable-workflow-ops

tests/integration/polyglot_fixtures.py

@@ -10,6 +10,25 @@
 
 from durable_workflow import activity, workflow
 
+PHP_VERSION_MARKER_RECORDED_EVENT = {
+    "event_type": "VersionMarkerRecorded",
+    "payload": {
+        "sequence": 1,
+        "change_id": "polyglot-version-marker",
+        "version": 2,
+        "min_supported": 1,
+        "max_supported": 2,
+    },
+}
+
+PHP_VERSION_MARKER_EXPECTED_KEYS = [
+    "sequence",
+    "change_id",
+    "version",
+    "min_supported",
+    "max_supported",
+]
+
 
 @activity.defn(name="tests.polyglot.python-activity")
 async def polyglot_python_activity(input_data: dict) -> dict:
@@ -62,3 +81,15 @@ def run(self, ctx, data: dict):  # type: ignore[no-untyped-def]
                 "result_has_runtime": php_result.get("runtime") == "php" if isinstance(php_result, dict) else False,
             },
         }
+
+
+@workflow.defn(name="tests.polyglot.version-marker-python-workflow")
+class PolyglotVersionMarkerWorkflow:
+    """Python replay fixture for PHP-emitted VersionMarkerRecorded history."""
+
+    def run(self, ctx):  # type: ignore[no-untyped-def]
+        version = yield ctx.get_version("polyglot-version-marker", 1, 2)
+        if version >= 2:
+            return (yield ctx.schedule_activity("tests.polyglot.version-marker-new-path", []))
+
+        return (yield ctx.schedule_activity("tests.polyglot.version-marker-old-path", []))

tests/test_replay.py

@@ -22,6 +22,11 @@
     WorkflowContext,
     replay,
 )
+from tests.integration.polyglot_fixtures import (
+    PHP_VERSION_MARKER_EXPECTED_KEYS,
+    PHP_VERSION_MARKER_RECORDED_EVENT,
+    PolyglotVersionMarkerWorkflow,
+)
 
 
 @workflow.defn(name="simple-return")
@@ -701,6 +706,25 @@ def test_server_command_defaults(self) -> None:
 
 
 class TestVersionMarker:
+    def test_replays_php_emitted_version_marker_wire_fixture(self) -> None:
+        payload = PHP_VERSION_MARKER_RECORDED_EVENT["payload"]
+
+        assert sorted(payload) == sorted(PHP_VERSION_MARKER_EXPECTED_KEYS)
+        assert payload == {
+            "sequence": 1,
+            "change_id": "polyglot-version-marker",
+            "version": 2,
+            "min_supported": 1,
+            "max_supported": 2,
+        }
+
+        outcome = replay(PolyglotVersionMarkerWorkflow, [PHP_VERSION_MARKER_RECORDED_EVENT], [])
+
+        assert len(outcome.commands) == 1
+        cmd = outcome.commands[0]
+        assert isinstance(cmd, ScheduleActivity)
+        assert cmd.activity_type == "tests.polyglot.version-marker-new-path"
+
     def test_first_replay_records_marker_and_continues(self) -> None:
         outcome = replay(VersionWorkflow, [], [])
         assert len(outcome.commands) == 2