Skip to content

Instantly share code, notes, and snippets.

VERSION='v1.0.3'
# DAG Factory
factory = DAGFactory(config.environment)
the_first_dag = factory.create('Module_1').build()
process_messages_dag = factory.create('Module_2').build()
def create_main_dag(dag_id, org_config):