dag_generator.generator

dag_generator

def dag_generator(dag_id_whitelist: Iterable[str] = None) -> Generator[TDag, None, None]

DAG Object Generator

Arguments:

• dag_id_whitelist: A list of dag_ids to be generated. If empty, then all will be generated.

generate_dag

def generate_dag(dag_dir: str, dag_id: str = None) -> TDag

Get the DAG object by dag_dir @param dag_dir: Full path to the directory @param dag_id: Dag_id is considered the directory name if dag_path is not specified @return: