From ab1a81eece1b4b0aa09889ab47c88329e9ae4b07 Mon Sep 17 00:00:00 2001 From: hussein-awala Date: Tue, 26 Dec 2023 00:04:33 +0100 Subject: [PATCH] Consolidate loading delete_local_logs conf in hdfs task handler --- airflow/providers/apache/hdfs/log/hdfs_task_handler.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/airflow/providers/apache/hdfs/log/hdfs_task_handler.py b/airflow/providers/apache/hdfs/log/hdfs_task_handler.py index 648b42e3d9ea6..b685653dd6a97 100644 --- a/airflow/providers/apache/hdfs/log/hdfs_task_handler.py +++ b/airflow/providers/apache/hdfs/log/hdfs_task_handler.py @@ -41,10 +41,8 @@ def __init__( self._hook = None self.closed = False self.upload_on_close = True - self.delete_local_copy = ( - kwargs["delete_local_copy"] - if "delete_local_copy" in kwargs - else conf.getboolean("logging", "delete_local_logs", fallback=False) + self.delete_local_copy = kwargs.get( + "delete_local_copy", conf.getboolean("logging", "delete_local_logs") ) @cached_property