Skip to content

Commit

Permalink
Fix typo in task_runner for AirflowConfigException (apache#15067)
Browse files Browse the repository at this point in the history
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: apache#14933
  • Loading branch information
Berk Sudan authored Mar 29, 2021
1 parent 6415489 commit 7949226
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/task/task_runner/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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}".'
)

Expand Down

0 comments on commit 7949226

Please sign in to comment.