This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-4-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 97c5124b1647bc27392e09a86d2c032b12bc6eb8 Author: Daniel Standish <[email protected]> AuthorDate: Mon Sep 19 12:04:23 2022 -0700 Don't import kubernetes unless you have a V1Pod (#26496) When serializing a DAG which doesn't involve a k8s pod, we can avoid importing the kubernetes library. (cherry picked from commit 9ea7b1f7c6e62fceb895f7414b3e707888806573) --- airflow/serialization/serialized_objects.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py index 969b6014db..87fd56882a 100644 --- a/airflow/serialization/serialized_objects.py +++ b/airflow/serialization/serialized_objects.py @@ -399,7 +399,7 @@ class BaseSerialization: return cls._encode({str(k): cls.serialize(v) for k, v in var.items()}, type_=DAT.DICT) elif isinstance(var, list): return [cls.serialize(v) for v in var] - elif _has_kubernetes() and isinstance(var, k8s.V1Pod): + elif var.__class__.__name__ == 'V1Pod' and _has_kubernetes() and isinstance(var, k8s.V1Pod): json_pod = PodGenerator.serialize_pod(var) return cls._encode(json_pod, type_=DAT.POD) elif isinstance(var, DAG):
