diff --git a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py index e095bd7802d91..65fd4d89d2d20 100644 --- a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py +++ b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py @@ -106,10 +106,9 @@ def get_crd_fields(self, body: dict) -> tuple[str, str, str, str]: group = api_version[0 : api_version.find("/")] version = api_version[api_version.find("/") + 1 :] - namespace = None - if body.get("metadata"): - metadata: dict = body.get("metadata", None) - namespace = metadata.get("namespace", None) + metadata = body.get("metadata", {}) if body else None + namespace = metadata.get("namespace") if metadata else None + if namespace is None: namespace = self.get_namespace()