From 794922649982b2a6c095f7fa6be4e5d6a6d9f496 Mon Sep 17 00:00:00 2001 From: Berk Sudan Date: Tue, 30 Mar 2021 02:20:53 +0300 Subject: [PATCH] Fix typo in task_runner for ``AirflowConfigException`` (#15067) Key name "executor" has changed to "task_runner" since this value does not belong to the executor, but the task_runner. This PR fixes the typo in the exception message. closes: #14933 --- airflow/task/task_runner/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/task/task_runner/__init__.py b/airflow/task/task_runner/__init__.py index 0b61d795e77bc..30f11d25b8a4a 100644 --- a/airflow/task/task_runner/__init__.py +++ b/airflow/task/task_runner/__init__.py @@ -56,7 +56,7 @@ def get_task_runner(local_task_job): task_runner_class = import_string(_TASK_RUNNER_NAME) except ImportError: raise AirflowConfigException( - f'The task runner could not be loaded. Please check "executor" key in "core" section. ' + f'The task runner could not be loaded. Please check "task_runner" key in "core" section. ' f'Current value: "{_TASK_RUNNER_NAME}".' )