У меня есть простой пример, показывающий DAG с двумя уровнями. При запуске этот даг не работает из-за искусственной ошибки, есть одна failed задача и одна upstream_fail. bug =…
airflow
Вне оператора мне нужно вызвать SubdagOperator и передать ему возвращаемое значение оператора, используя xcom. Я видел множество решений (Airflow — Как пройти xcom в функцию Python, Как для…
Я новичок в воздушном потоке и пытаюсь понять, что execution_date означает в контексте воздушного потока. Я прочитал страницу руководства из документации по воздушному потоку, в которой говорится, что…
Я пытаюсь протестировать даг с более чем одной задачей в тестовой среде. Мне удалось протестировать отдельную задачу, связанную с дагом, но я хочу создать несколько задач в даге…