This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-2-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit a0934d154a1754af76e7aafb9a932b866caab450 Author: Daniel Standish <[email protected]> AuthorDate: Mon Nov 1 09:22:23 2021 -0700 Clarify dag-not-found error message (#19338) In this context, what's really happening is, we can't find the dag. From a user perspective, when you encounter this error, 'could not find the dag' is a more intuitive representation of the problem than 'could not find the dag_id'. (cherry picked from commit 0be26b47439de11935b8b8b246a4cad35fbb8659) --- airflow/utils/cli.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/airflow/utils/cli.py b/airflow/utils/cli.py index 6415676..db58b88 100644 --- a/airflow/utils/cli.py +++ b/airflow/utils/cli.py @@ -177,8 +177,7 @@ def get_dag_by_file_location(dag_id: str): dag_model = DagModel.get_current(dag_id) if dag_model is None: raise AirflowException( - 'dag_id could not be found: {}. Either the dag did not exist or it failed to ' - 'parse.'.format(dag_id) + f"Dag {dag_id!r} could not be found; either it does not exist or it failed to parse." ) dagbag = DagBag(dag_folder=dag_model.fileloc) return dagbag.dags[dag_id] @@ -191,8 +190,7 @@ def get_dag(subdir: Optional[str], dag_id: str) -> "DAG": dagbag = DagBag(process_subdir(subdir)) if dag_id not in dagbag.dags: raise AirflowException( - 'dag_id could not be found: {}. Either the dag did not exist or it failed to ' - 'parse.'.format(dag_id) + f"Dag {dag_id!r} could not be found; either it does not exist or it failed to parse." ) return dagbag.dags[dag_id]
