You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/04/06 16:37:13 UTC

[airflow] branch main updated: Pickle dag exception string fix (#22760)

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 3fe5a21d75 Pickle dag exception string fix (#22760)
3fe5a21d75 is described below

commit 3fe5a21d751b20c4be4ab54223a5622143e2dbb4
Author: Rafael Carrasco <ra...@gmail.com>
AuthorDate: Wed Apr 6 11:37:04 2022 -0500

    Pickle dag exception string fix (#22760)
---
 airflow/utils/cli.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/utils/cli.py b/airflow/utils/cli.py
index 9629951a67..686edb7cb8 100644
--- a/airflow/utils/cli.py
+++ b/airflow/utils/cli.py
@@ -236,7 +236,7 @@ def get_dag_by_pickle(pickle_id, session=None):
 
     dag_pickle = session.query(DagPickle).filter(DagPickle.id == pickle_id).first()
     if not dag_pickle:
-        raise AirflowException("Who hid the pickle!? [missing pickle]")
+        raise AirflowException(f"pickle_id could not be found in DagPickle.id list: {pickle_id}")
     pickle_dag = dag_pickle.pickle
     return pickle_dag