SubDagOperator

Apache Airflow Certified

This runs a sub dag. By convention, a sub dag’s dag_id should be prefixed by its parent and a dot. As in parent.child. Although SubDagOperator can occupy a pool/concurrency slot, user can specify the mode=reschedule so that the slot will be released periodically to avoid potential deadlock.

View Source

Last Updated: Dec. 8, 2020

Access Instructions

Install the Apache Airflow provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

subdagthe DAG object to run as a subdag of the current DAG.
sessionsqlalchemy session
confdictConfiguration for the subdag
propagate_skipped_stateby setting this argument you can define whether the skipped state of leaf task(s) should be propagated to the parent dag's downstream task.

Documentation

This runs a sub dag. By convention, a sub dag’s dag_id should be prefixed by its parent and a dot. As in parent.child. Although SubDagOperator can occupy a pool/concurrency slot, user can specify the mode=reschedule so that the slot will be released periodically to avoid potential deadlock.

Was this page helpful?