Как получить экземпляры задач для последующих задач по их task_id в Airflow? - PullRequest
1 голос
/ 17 марта 2020

Можно ли каким-то образом извлечь объект экземпляра задачи для исходящих задач из контекста, переданного в python_callable в PythonOperator. Сценарий использования заключается в том, что я хотел бы проверить состояние двух задач сразу после ветвления, чтобы проверить, какая из них была запущена, а какая пропущена, чтобы я мог запросить правильную задачу на возвращаемое значение через xcom.

Спасибо

...