airflow_config.DAG¶

class airflow_config.DAG(config: Configuration = None, **kwargs)[source]¶

Bases: DAG

__init__(config: Configuration = None, **kwargs)[source]¶: Method generated by attrs for class DAG.

Methods

`__init__`([config])	Method generated by attrs for class DAG.
`add_task`(task)	Add a task to the DAG.
`add_tasks`(tasks)	Add a list of tasks to the DAG.
`bulk_write_to_db`(bundle_name, ...[, session])	Ensure the DagModel rows for the given dags are up-to-date in the dag table in the DB.
`clear`([exclude_run_ids])	Clear a set of task instances associated with the current dag for a specified date range.
`clear_dags`(dags[, start_date, end_date, ...])
`cli`()	Exposes a CLI specific to this DAG.
`create_dagrun`(*, run_id[, logical_date, ...])	Create a run for this DAG to run its tasks.
`deactivate_stale_dags`(expiration_date[, session])	Deactivate any DAGs that were last touched by the scheduler before the expiration date.
`deactivate_unknown_dags`(active_dag_ids[, ...])	Given a list of known DAGs, deactivate any other DAGs that are marked as active in the ORM.
`fetch_dagrun`(dag_id, run_id[, session])	Return the dag run for a given run_id if it exists, otherwise none.
`from_sdk_dag`(dag)	Create a new (Scheduler) DAG object from a TaskSDKDag.
`get_active_runs`()	Return a list of dag run logical dates currently running.
`get_bundle_name`([session])	Return the bundle name this DAG is in.
`get_bundle_version`([session])	Return the bundle version that was seen when this dag was processed.
`get_concurrency_reached`([session])	Return a boolean indicating whether the max_active_tasks limit for this DAG has been reached.
`get_dagrun`(run_id[, session])
`get_dagruns_between`(start_date, end_date[, ...])	Return the list of dag runs between start_date (inclusive) and end_date (inclusive).
`get_edge_info`(upstream_task_id, ...)	Return edge information for the given pair of tasks or an empty edge if there is no information.
`get_is_active`([session])	Return a boolean indicating whether this DAG is active.
`get_is_paused`([session])	Return a boolean indicating whether this DAG is paused.
`get_is_stale`([session])	Return a boolean indicating whether this DAG is stale.
`get_last_dagrun`([session, ...])
`get_latest_logical_date`([session])	Return the latest date for which at least one dag run exists.
`get_next_data_interval`(dag_model)	Get the data interval of the next scheduled run.
`get_num_task_instances`(dag_id[, run_id, ...])	Return the number of task instances in the given DAG.
`get_run_data_interval`(run)	Get the data interval of this run.
`get_task`(task_id)
`get_task_assets`([inlets, outlets, of_type])
`get_task_instances`([start_date, end_date, ...])
`get_task_instances_before`(base_date, num, *)	Get `num` task instances before (including) `base_date`.
`get_template_env`(*[, force_sandboxed])	Build a Jinja2 environment.
`has_dag_runs`([session, ...])
`has_task`(task_id)
`has_task_group`(task_group_id)
`infer_automated_data_interval`(logical_date)	Infer a data interval for a run against this DAG.
`iter_dagrun_infos_between`(earliest, latest, *)	Yield DagRunInfo using this DAG's timetable between given interval.
`logger`()	Return a logger.
`next_dagrun_info`(last_automated_dagrun, *[, ...])	Get information about the next DagRun of this dag after `date_last_automated_dagrun`.
`param`(name[, default])	Return a DagParam object for current dag.
`partial_subset`(task_ids[, ...])	Return a subset of the current dag based on regex matching one or more tasks.
`resolve_template_files`()
`set_dependency`(upstream_task_id, ...)	Set dependency between two tasks that already have been added to the DAG using add_task().
`set_edge_info`(upstream_task_id, ...)	Set the given edge information on the DAG.
`set_task_group_state`(*, group_id[, run_id, ...])	Set TaskGroup to the given state and clear downstream tasks in failed or upstream_failed state.
`set_task_instance_state`(*, task_id[, ...])	Set the state of a TaskInstance and clear downstream tasks in failed or upstream_failed state.
`sync_to_db`([session])	Save attributes about this DAG to the DB.
`test`([run_after, logical_date, run_conf, ...])	Execute one single DagRun for a given DAG and logical date.
`topological_sort`()	Sorts tasks in topographical order, such that a task comes after any of its upstream dependencies.
`validate`()	Validate the DAG has a coherent setup.
`validate_executor_field`()
`validate_setup_teardown`()	Validate that setup and teardown tasks are configured properly.

Attributes

`dag_id`
`folder`	Folder location of where the DAG object is instantiated.
`get_serialized_fields`
`leaves`	Return nodes with no children.
`log`	Return a logger.
`owner`	Return list of all owners found in DAG tasks.
`roots`	Return nodes with no parents.
`safe_dag_id`
`task`
`task_group_dict`
`task_ids`
`tasks`
`tasks_upstream_of_teardowns`
`teardowns`
`timetable_summary`
`partial`
`last_loaded`
`max_consecutive_failed_dag_runs`
`description`
`default_args`
`start_date`
`end_date`
`timezone`
`schedule`
`timetable`
`template_searchpath`
`template_undefined`
`user_defined_macros`
`user_defined_filters`
`max_active_tasks`
`max_active_runs`
`dagrun_timeout`
`sla_miss_callback`
`catchup`
`on_success_callback`
`on_failure_callback`
`doc_md`
`params`
`access_control`
`is_paused_upon_creation`
`jinja_environment_kwargs`
`render_template_as_native_obj`
`tags`
`owner_links`
`auto_register`
`fail_fast`
`dag_display_name`
`task_dict`
`task_group`
`fileloc`
`relative_fileloc`
`edge_info`
`has_on_success_callback`
`has_on_failure_callback`
`disable_bundle_versioning`