You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2020/08/13 22:45:07 UTC

[airflow] 02/05: Add __repr__ to SerializedDagModel (#9862)

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

kaxilnaik pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git

commit d5372d5f33d35abb6b959ddb95f022a4da5de4e3
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Sat Jul 18 22:28:31 2020 +0100

    Add __repr__ to SerializedDagModel (#9862)
    
    Before: `<airflow.models.serialized_dag.SerializedDagModel at 0x7fab30d68c50>`
    After: `<SerializedDag: example_xcom_args>`
    (cherry picked from commit 1dc852d4afe8073cf9b410cc5e98955d2028cb4a)
---
 airflow/models/serialized_dag.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/airflow/models/serialized_dag.py b/airflow/models/serialized_dag.py
index c1a647a..c655e34 100644
--- a/airflow/models/serialized_dag.py
+++ b/airflow/models/serialized_dag.py
@@ -76,6 +76,9 @@ class SerializedDagModel(Base):
         self.data = SerializedDAG.to_dict(dag)
         self.last_updated = timezone.utcnow()
 
+    def __repr__(self):
+        return "<SerializedDag: {}>".format(self.dag_id)
+
     @classmethod
     @db.provide_session
     def write_dag(cls,