dpti.dags package
dpti.dags.dp_ti_gdi module
- class dpti.dags.dp_ti_gdi.GDIDAGFactory(gdi_name, dag_work_base)[source]
Bases: object
Methods
- create_loop_dag()[source]
- create_main_dag()[source]
- dagargs: ClassVar[Dict[str, object]] = {'default_args': {'owner': 'airflow', 'start_date': datetime.datetime(2018, 1, 1, 0, 0)}, 'schedule_interval': None}
- default_args: ClassVar[Dict[str, object]] = {'owner': 'airflow', 'start_date': datetime.datetime(2018, 1, 1, 0, 0)}
- class dpti.dags.dp_ti_gdi.GDIWorkflow(dag_name, var_name)[source]
Bases: object
Methods
- get_dag_run_state()[source]
- trigger_loop(submission, task_list, mdata)[source]
- wait_until_end()[source]
dpti.dags.utils module
- dpti.dags.utils.get_empty_submission(job_work_dir, context)[source]