test_dag.py

from csst_dag import CSST_DAGS

# dfs = DFS()
# os.environ


test_kwargs = dict(
    dataset="csst-msc-c9-25sqdeg-v3",
    instrument="MSC",
    obs_type="WIDE",
    obs_group="W1",
    obs_id="10100100412",
    proposal_id=None,
    prc_status=-1024,
)

dag = CSST_DAGS.get("csst-msc-l1-mbi")
dag_group_run, dag_run_list = dag.run(
    **test_kwargs,
    extra_kwargs={"a": 1},
)

# currently defined DAGs
for dag in CSST_DAGS.keys():
    print(dag)
# csst-msc-l1-qc0
# csst-msc-l1-mbi
# csst-msc-l1-ast
# csst-msc-l1-sls
# csst-msc-l1-ooc
# csst-mci-l1
# csst-mci-l1-qc0
# csst-ifs-l1
# csst-cpic-l1
# csst-cpic-l1-qc0
# csst-hstdm-l1