Report a schema error's path the same way under every jsonschema version

jsonschema 4.26 writes $.dag.tasks[2]['__type'] where 4.23 writes
$.dag.tasks[2].__type, so the import error and three tests changed with
the installed version. Build the path from the error's absolute path.

Co-Authored-By: Claude <noreply@anthropic.com>

Author: jason810496

airflow-core/src/airflow/serialization/serialized_objects.py

@@ -300,6 +300,16 @@ def _decode_start_trigger_args(var: dict[str, Any]) -> StartTriggerArgs:
     )
 
 
+def _build_json_path(error: ValidationError) -> str:
+    """
+    Return where *error* is in the document, such as ``$.dag.tasks[2].__type``.
+
+    Unlike ``ValidationError.json_path``, whose quoting of a key such as ``__type`` depends on the
+    jsonschema version, this is the same under every version.
+    """
+    return "$" + "".join(f"[{part}]" if isinstance(part, int) else f".{part}" for part in error.absolute_path)
+
+
 class _XComRef(NamedTuple):
     """
     Store info needed to create XComArg.
@@ -2182,7 +2192,7 @@ def validate_serialized_dag(cls, serialized_obj: dict[str, Any]) -> SerializedDA
             cls.validate_schema(serialized_obj)
         except ValidationError as e:
             raise DeserializationError(
-                dag_id, f"Dag {dag_id!r} does not match the schema at {e.json_path}: {e.message}"
+                dag_id, f"Dag {dag_id!r} does not match the schema at {_build_json_path(e)}: {e.message}"
             ) from e
         task_ids = collections.Counter(
             task[Encoding.VAR]["task_id"] for task in serialized_obj["dag"]["tasks"]

airflow-core/tests/unit/serialization/test_dag_serialization.py

@@ -5209,12 +5209,12 @@ def test_returns_the_deserialized_dag(self):
             pytest.param({}, "$.dag.tasks[2]", id="empty"),
             pytest.param("x", "$.dag.tasks[2]", id="not-an-object"),
             pytest.param(
-                {"__type": "dag", "__var": {"task_id": "t"}}, "$.dag.tasks[2]['__type']", id="wrong-type"
+                {"__type": "dag", "__var": {"task_id": "t"}}, "$.dag.tasks[2].__type", id="wrong-type"
             ),
-            pytest.param({"__type": "operator", "__var": {}}, "$.dag.tasks[2]['__var']", id="no-task-id"),
+            pytest.param({"__type": "operator", "__var": {}}, "$.dag.tasks[2].__var", id="no-task-id"),
             pytest.param(
                 {"__type": "operator", "__var": {"task_id": 5}},
-                "$.dag.tasks[2]['__var'].task_id",
+                "$.dag.tasks[2].__var.task_id",
                 id="task-id-not-a-string",
             ),
         ],