I am trying to implement a Dynamic DAG logic in my Airflow instance. My tasks are generally SQL or Pyth