Воздушный поток 1.9 Присвоение приоритетных весов времени выполнения DagRuns - PullRequest
1 голос
/ 04 октября 2019

Я работаю над сценарием использования, где я запускаю даг с помощью TriggerDagRunOperator. Идея состоит в том, что я хочу назначать приоритеты в некоторых случаях, а в остальных случаях я хочу, чтобы DAG принимала приоритеты по умолчанию.

Можно ли назначить вес приоритета во время выполнения для целевой DAG с помощью TriggerDagRunOperator?

PS: я использую Airflow 1.9.

...