handle params serialized in 2.2.0, when param attrs were not run thro…

…ugh serializer
apache · Oct 29, 2021 · 0fc6c0e · 0fc6c0e
1 parent f98768f
commit 0fc6c0e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py
@@ -417,7 +417,10 @@ def _serialize_param(cls, param: Param):
     @classmethod
     def _deserialize_param(cls, param_dict: Dict):
         param_class = import_string(param_dict.pop(Param.CLASS_IDENTIFIER))
-        param_kwargs = cls._deserialize(param_dict)
+        try:
+            param_kwargs = cls._deserialize(param_dict)
+        except KeyError:
+            param_kwargs = param_dict
         return param_class(**param_kwargs)
 
     @classmethod