From 5f5039a6531d9366ac7ffc9a05492b7a93bc8f87 Mon Sep 17 00:00:00 2001 From: Jens Scheffler Date: Wed, 17 Jul 2024 18:58:12 +0200 Subject: [PATCH] Fix pytests --- tests/api_connexion/schemas/test_xcom_schema.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/api_connexion/schemas/test_xcom_schema.py b/tests/api_connexion/schemas/test_xcom_schema.py index eb3220626dcef..7a10b7e7a47b7 100644 --- a/tests/api_connexion/schemas/test_xcom_schema.py +++ b/tests/api_connexion/schemas/test_xcom_schema.py @@ -25,7 +25,7 @@ XComCollection, xcom_collection_item_schema, xcom_collection_schema, - xcom_schema, + xcom_schema_string, ) from airflow.models import DagRun, XCom from airflow.utils.dates import parse_execution_date @@ -199,7 +199,7 @@ def test_serialize(self, create_xcom, session): value=pickle.dumps(b"test_binary"), ) xcom_model = session.query(XCom).first() - deserialized_xcom = xcom_schema.dump(xcom_model) + deserialized_xcom = xcom_schema_string.dump(xcom_model) assert deserialized_xcom == { "key": "test_key", "timestamp": self.default_time, @@ -220,7 +220,7 @@ def test_deserialize(self): "dag_id": "test_dag", "value": b"test_binary", } - result = xcom_schema.load(xcom_dump) + result = xcom_schema_string.load(xcom_dump) assert result == { "key": "test_key", "timestamp": self.default_time_parsed,