airflow.models.dagpickle

Module Contents

class airflow.models.dagpickle.DagPickle(dag)[source]

Bases: airflow.models.base.Base

Dags can originate from different places (user repos, master repo, …) and also get executed in different places (different executors). This object represents a version of a DAG and becomes a source of truth for a BackfillJob execution. A pickle is a native python serialized object, and in this case gets stored in the database for the duration of the job.

The executors pick up the DagPickle id and read the dag definition from the database.

id[source]
pickle[source]
created_dttm[source]
pickle_hash[source]
__tablename__ = dag_pickle[source]