Factorize serialization logic for asset

apache · Jan 22, 2025 · 3859d7a · 3859d7a
1 parent a35ee1c
commit 3859d7a
Showing 1 changed file with 1 addition and 11 deletions.
diff --git 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: