Is there a way to obtain the dag_id from a DAG in Airflow from within one of its tasks in Python?
My purpose is to delete a table (that has been created with the same name of the dag) inside a Task.
1 Answers
Two ways:
- You can do it via Jinja macros if you have templated field https://airflow.apache.org/docs/apache-airflow/stable/macros-ref.html#macros-reference
- same macros are available in the form of
contextdictionary passed toexecutemethod of your operator.
Related