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