utkarsharma2

"""Dag Factory"""
from datetime import datetime
from airflow import DAG

def create_dag(schedule, default_args, definition):
    """Create dags dynamically."""
    with DAG(
        definition["name"], schedule_interval=schedule, default_args=default_args
    ) as dag: