и еще один вопрос из разряда глупых: почему он теперь делает этот таск без остановки и по 16 раз за итерацию?
start_date=datetime(2020, 4, 20) – может "нагонять", если включен catchup в конфиге самого airflow. (catchup_by_default называется опция, в секции scheduler). Тогда создастся куча даг ранов, max_active_runs_per_dag = 16 как раз по дефолту
Если в пределах одного даг рана такое происходит – нужно смотреть логи, вариантов много, не свангуешь
