From 73a140121315d7dd1d302372dc560e5493e76604 Mon Sep 17 00:00:00 2001 From: FingerLiu Date: Wed, 12 Oct 2022 10:53:54 +0800 Subject: [PATCH] Fix log message for kubernetes hooks --- airflow/providers/cncf/kubernetes/hooks/kubernetes.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/providers/cncf/kubernetes/hooks/kubernetes.py b/airflow/providers/cncf/kubernetes/hooks/kubernetes.py index a0ace357f9acf..c23521ec159cc 100644 --- a/airflow/providers/cncf/kubernetes/hooks/kubernetes.py +++ b/airflow/providers/cncf/kubernetes/hooks/kubernetes.py @@ -290,9 +290,9 @@ def create_custom_object( plural=plural, name=body_dict["metadata"]["name"], ) - self.log.warning("Deleted SparkApplication with the same name.") + self.log.warning("Deleted custom resource with the same name.") except client.rest.ApiException: - self.log.info("SparkApp %s not found.", body_dict['metadata']['name']) + self.log.info("Custom resource %s not found.", body_dict['metadata']['name']) try: response = api.create_namespaced_custom_object(