From 3859d7ac2cd0dd6d0d38c32c28b27e711694c5e6 Mon Sep 17 00:00:00 2001 From: vincbeck Date: Wed, 22 Jan 2025 14:37:25 -0500 Subject: [PATCH] Factorize serialization logic for asset --- airflow/serialization/serialized_objects.py | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py index 27f2d1bb382b6..a570caf63101f 100644 --- a/airflow/serialization/serialized_objects.py +++ b/airflow/serialization/serialized_objects.py @@ -305,17 +305,7 @@ def decode_asset_condition(var: dict[str, Any]) -> BaseAsset: """ dat = var["__type"] if dat == DAT.ASSET: - serialized_watchers = var["watchers"] if "watchers" in var else [] - return Asset( - name=var["name"], - uri=var["uri"], - group=var["group"], - extra=var["extra"], - watchers=[ - AssetWatcher(name=watcher["name"], trigger=watcher["trigger"]) - for watcher in serialized_watchers - ], - ) + return BaseSerialization.deserialize(encoded_var=var) if dat == DAT.ASSET_ALL: return AssetAll(*(decode_asset_condition(x) for x in var["objects"])) if dat == DAT.ASSET_ANY: