обновление воздушного потока 1.9 до воздушного потока 1.10.2: ошибка task_log_reader

Question

Я столкнулся с ошибкой "task_log_reader" после обновления потока воздуха с версии 1.9 до версии 1.10.2.

Ошибка: «airflow.exceptions.AirflowConfigException: сконфигурированный task_log_reader 'task' не был обработчиком регистратора 'airflow.task'"

Я изменил airflow.cfg, как в https://github.com/apache/airflow/blob/1.10.2/airflow/config_templates/default_airflow.cfg:

task_log_reader = task
log_filename_template = {{{{ ti.dag_id }}}}/{{{{ ti.task_id }}}}/{{{{ ts }}}}/{{{{ try_number }}}}.log
log_processor_filename_template = {{{{ filename }}}}.log

• и т. Д.

Чего мне не хватает?

Answer 1

Не уверен, что это все еще актуально; У меня была похожая проблема, но с другим сообщением об ошибке.

Вот как должен выглядеть правильный файл конфигурации:

log_filename_template = {{ ti.dag_id }}/{{ ti.task_id }}/{{ ts }}/{{ try_number }}.log
log_processor_filename_template = {{ filename }}.log