Airflow 1.9 runtime assignment of Priority Weights to DagRuns

Viewed 314

I'm working on a usecase where I am triggering dags using TriggerDagRunOperator. The idea is that I want to assign priorities in some cases, and in rest cases I want DAG to assume default priorities.

Is it possible to assign priority weight at run time to target DAG using TriggerDagRunOperator?

PS: I'm using Airflow 1.9.

0 Answers
Related