AGLOW Subdags

To make it easier to build complex workflows; subdags can be incorporated in the parent workflow.

SKSP_Calibrator

The calibrator workflow for the SKSP data processing pipeline.

AGLOW.airflow.subdags.SKSP_calibrator.archive_all_tokens(token_type, archive_location, delete=False)[source]
AGLOW.airflow.subdags.SKSP_calibrator.archive_tokens_from_task(token_task, delete=False, **context)[source]

Determines whic tokens to archive and saves them. delete if necessary

AGLOW.airflow.subdags.SKSP_calibrator.calibrator_subdag(parent_dag_name, subdagname, dag_args, args_dict=None)[source]
AGLOW.airflow.subdags.SKSP_calibrator.test_check_staged(srm_variable, **context)[source]