I am using the Airflow scheduler and am trying to understand how to customize the DAGs that will be used by Airflow, since they appear to be generated from my

meltano.yml

at runtime by

orchestrate/airflow/dags/meltano_dag_generator.py

. Ideally, I would be able to update the

on_success_callback

and

on_failure_callback

(for the task) to perform notifications. Is the expectation that these customizations should just happen in

orchestrate/airflow/meltano_dag_generator.py

? Or is there a better place? (I see the docs have a different name for that file, I'm not sure why my very recent install used that name.)