dag_generator.dags.yaml_dag

YamlDag Objects

class YamlDag(TDag)

DAG created based on the description in the yaml file

Arguments:

• dag_dir: Directory with TDag.META_FILE
• config: Optional and decomposed meta.yaml file

attach_task

def attach_task(task: dict) -> None

Add task to DAG

Arguments:

• task: Dictionary with task attributes