msc.py

# Given dataset and batchid, trigger all DAGs for MSC

from csst_dag.constants import MSC_MBI_CHIPID
from csst_dfs_client import plan, level0
import argparse


# python -m csst_dag.trigger.csst-msc-l1-mbi -h
# python -m csst_dag.trigger.csst-msc-l1-mbi --dataset csst-msc-c9-25sqdeg-v3 --batch-id
parser = argparse.ArgumentParser(
    description="Trigger for DAG csst-msc-l1-mbi",
    formatter_class=argparse.ArgumentDefaultsHelpFormatter,
)
parser.add_argument("--dataset", type=str, help="Dataset name")
# parser.add_argument("--instrument", type=str, help="Instrument name", default="MSC")
parser.add_argument("--project-id", type=str, help="Project ID", default="None")
# parser.add_argument(
#     "--file-type", type=str, help="File type (SCI/CAL/REF)", default="SCI"
# )
# parser.add_argument("--obs-type", type=str, help="Observation type", default="WIDE")
parser.add_argument("--batch-id", type=str, help="Batch ID", default="default")
args = parser.parse_args()
print(args)

OBSTYPE_DAG_MAP = {
    "WIDE": "csst-msc-l1-mbi",
    "DEEP": "csst-msc-l1-mbi",
    "BIAS": "csst-msc-l1-mbi",
    "DARK": "csst-msc-l1-mbi",
    "FLAT": "csst-msc-l1-mbi",
}
for obs_type in ["WIDE", "DEEP"]:
    pass