Skip to content

Commit a5fdbc4

Browse files
committed
Capitalize default executor key
1 parent 3be292c commit a5fdbc4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

airflow/utils/log/file_task_handler.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,7 @@ class FileTaskHandler(logging.Handler):
180180
"Operator inherits from empty operator and thus does not have logs"
181181
)
182182
executor_instances: dict[str, BaseExecutor] = {}
183-
default_executor_key = "_default_executor"
183+
DEFAULT_EXECUTOR_KEY = "_default_executor"
184184

185185
def __init__(
186186
self,
@@ -327,12 +327,12 @@ def _get_executor_get_task_log(
327327
:param ti: task instance object
328328
:return: get_task_log method of the executor
329329
"""
330-
executor_name = ti.executor or self.default_executor_key
330+
executor_name = ti.executor or self.DEFAULT_EXECUTOR_KEY
331331
executor = self.executor_instances.get(executor_name)
332332
if executor is not None:
333333
return executor.get_task_log
334334

335-
if executor_name == self.default_executor_key:
335+
if executor_name == self.DEFAULT_EXECUTOR_KEY:
336336
self.executor_instances[executor_name] = ExecutorLoader.get_default_executor()
337337
else:
338338
self.executor_instances[executor_name] = ExecutorLoader.load_executor(executor_name)

0 commit comments

Comments
 (0)