dag_creator.py

'''
### DAG Creator
This workflow listens for Triggers. Based on config parameters passed., It creates DAG.
'''
from datetime import timedelta, datetime
from airflow import DAG
from airflow.utils.dates import days_ago
from operators.rest_to_template_wrapper_operator import RestToTemplateWrapperOperator

# These args will get passed on to each operator
# You can override them on a per-task basis during operator initialization
default_args = {
    'schedule_interval': None, # exclusively “externally triggered” DAG
    'start_date': days_ago(2),
    'catchup': False,
    'owner': 'admin',
}
dag = DAG(
    'dag-creator',
    default_args=default_args,
    description='An exclusive workflow for creating another workflow',
)

t1 = RestToTemplateWrapperOperator(task_id="generate-dag", dag=dag, provide_context=True)

dag.doc_md = __doc__

t1.doc_md = """\
#### Generate dag
This action generates a DAG workflow.
"""