'Airflow- Pass Parameters at runtime
I have a DAG. How I can I pass parameters to the DAG at runtime and start the DAG? Basically, the DAG can take upto 10 values for a param (say, number). Based on the number param value passed, the corresponding notebook will be called.
Is there a way to do this in Python programmatically to get the param that the user passes/enters and then, call the DAG?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
Solution | Source |
---|