diff --git a/airflow/executors/kubernetes_executor.py b/airflow/executors/kubernetes_executor.py index 5e748da1e827c..807c7f53e879d 100644 --- a/airflow/executors/kubernetes_executor.py +++ b/airflow/executors/kubernetes_executor.py @@ -294,7 +294,7 @@ def run_next(self, next_job: KubernetesJobType) -> None: and store relevant info in the current_jobs map so we can track the job's status """ - self.log.info('Kubernetes job is %s', str(next_job)) + self.log.info('Kubernetes job is %s', str(next_job).replace("\n", " ")) key, command, kube_executor_config, pod_template_file = next_job dag_id, task_id, run_id, try_number = key diff --git a/airflow/providers/cncf/kubernetes/utils/pod_launcher.py b/airflow/providers/cncf/kubernetes/utils/pod_launcher.py index 36c68b1091129..43bb513b11765 100644 --- a/airflow/providers/cncf/kubernetes/utils/pod_launcher.py +++ b/airflow/providers/cncf/kubernetes/utils/pod_launcher.py @@ -92,7 +92,9 @@ def run_pod_async(self, pod: V1Pod, **kwargs): ) self.log.debug('Pod Creation Response: %s', resp) except Exception as e: - self.log.exception('Exception when attempting to create Namespaced Pod: %s', json_pod) + self.log.exception( + 'Exception when attempting to create Namespaced Pod: %s', str(json_pod).replace("\n", " ") + ) raise e return resp