Мы недавно переключились с Airflow 1.9 на 1.10.1 и заметили, что все записи, которые делают операторы, теперь дублируются на base_task_runner, но мы не понимаем, почему:
[2019-02-14 11:42:15,998] base_sensor_operator.py:79 INFO - Success criteria met. Exiting.
[2019-02-14 11:42:15,998] base_task_runner.py:101 INFO - Job 346622: Subtask my_task [2019-02-14 11:42:15,998] base_sensor_operator.py:79 INFO - Success criteria met. Exiting.
Мырегистрировать вещи внутри операторов, используя self.log.info.Есть идеи, что вызывает дублирование и как его остановить?