(airflow) branch main updated: Consolidate loading delete_local_logs conf in hdfs task handler (#36422)

[joshfell]

This is an automated email from the ASF dual-hosted git repository.

joshfell pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new d986bed292 Consolidate loading delete_local_logs conf in hdfs task 
handler (#36422)
d986bed292 is described below

commit d986bed292696a34b8dce48a5e84e7b912ffed69
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Tue Dec 26 03:36:59 2023 +0100

    Consolidate loading delete_local_logs conf in hdfs task handler (#36422)
---
 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 648b42e3d9..b685653dd6 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 @@ class HdfsTaskHandler(FileTaskHandler, LoggingMixin):
         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