airflow.models.dagcode
¶
Module Contents¶
Attributes¶
- class airflow.models.dagcode.DagCode(full_filepath, source_code=None)[source]¶
Bases:
airflow.models.base.Base
A table for DAGs code.
dag_code table contains code of DAG files synchronized by scheduler.
For details on dag serialization see SerializedDagModel
- classmethod bulk_sync_to_db(filelocs, session=None)[source]¶
Writes code in bulk into database.
- Parameters
filelocs (Iterable[str]) – file paths of DAGs to sync
session – ORM Session
- classmethod remove_deleted_code(alive_dag_filelocs, session=None)[source]¶
Deletes code not included in alive_dag_filelocs.
- Parameters
alive_dag_filelocs (List[str]) – file paths of alive DAGs
session – ORM Session
- classmethod has_dag(fileloc, session=None)[source]¶
Checks a file exist in dag_code table.
- Parameters
fileloc (str) – the file to check
session – ORM Session