KS
Всегда воспринимал это сообщение как то, что скедулер отказывается запускать таску, так как она уже ранится.
вроде как это то что celery не подтвердил после таймаута что таска закончена и airflow пытается стартануть новую, но что-то идет не так.
и вроде как это можно починить переопределив эту штуку (1.9.0):
https://github.com/apache/incubator-airflow/blob/1.9.0/airflow/config_templates/default_celery.py#L31
но еще не проверила
и вроде как это можно починить переопределив эту штуку (1.9.0):
https://github.com/apache/incubator-airflow/blob/1.9.0/airflow/config_templates/default_celery.py#L31
но еще не проверила
