I'm learning to use airflow to schedule some python ETL processes. Each time I update my python code I have to restart the webserver and also rename the DAG before code changes are picked up by airflow. Is there anyway around this, especially so I dont have to be renaming my DAG each time I make changes?
On the webserver the changes may not be apparent but you can click the refresh button next to the DAG that you modify and it will reload the DAG manually.
The scheduler will always use the latest code without need for a reboot.
See here: https://gtoonstra.github.io/etl-with-airflow/gotchas.html
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With