airflow.models.dagpickle

Module Contents

Classes

DagPickle

Dags can originate from different places (user repos, main repo, ...)
class airflow.models.dagpickle.DagPickle(dag)[source]

Bases: airflow.models.base.Base

Dags can originate from different places (user repos, main 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]

Was this entry helpful?