Commit f0c06285 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

add csst_dag.cli.csst_cpic_l1

parent 73a4082e
""" """
Aim Aim
--- ---
Process an MSC dataset, given a set of parameters. Process a CPIC dataset, given a set of parameters.
Example Example
------- -------
python -m csst_dag.cli.csst_msc_l1 -h python -m csst_dag.cli.csst_cpic_l1 -h
python -m csst_dag.cli.csst_msc_l1 \ python -m csst_dag.cli.csst_cpic_l1 \
--dataset=csst-msc-c9-25sqdeg-v3 \ --dataset=csst-cpic-c11-hip71681-v1 \
--instrument=MSC \ --instrument=CPIC \
--obs-type=WIDE \ --obs-type=SCI \
--obs-group=W2 \ --obs-group=hip71681 \
--obs-id=10100232366 \ --obs-id=40100000001 \
--detector=09 \ --detector=VIS \
--prc-status=-1024 \ --prc-status=-1024 \
--batch-id=test-b1 \ --batch-id=test-b1 \
--priority=1 \ --priority=1 \
--pmapname=csst_000070.pmap \ --pmapname=csst_000070.pmap
--ref-cat=trilegal_093
""" """
import argparse import argparse
...@@ -29,7 +28,7 @@ import joblib ...@@ -29,7 +28,7 @@ import joblib
from csst_dag import CSST_DAGS, Dispatcher, BaseDAG, dfs from csst_dag import CSST_DAGS, Dispatcher, BaseDAG, dfs
parser = argparse.ArgumentParser( parser = argparse.ArgumentParser(
description="Scheduler for CSST MSC L1 pipeline.", description="Scheduler for CSST CPIC L1 pipeline.",
formatter_class=argparse.ArgumentDefaultsHelpFormatter, formatter_class=argparse.ArgumentDefaultsHelpFormatter,
) )
...@@ -48,9 +47,9 @@ parser.add_argument("--batch-id", type=str, help="Batch ID", default="test-batch ...@@ -48,9 +47,9 @@ parser.add_argument("--batch-id", type=str, help="Batch ID", default="test-batch
parser.add_argument("--priority", type=str, help="Task priority", default=1) parser.add_argument("--priority", type=str, help="Task priority", default=1)
# DAG parameters # DAG parameters
parser.add_argument("--pmapname", type=str, help="CCDS pmapname", default="") parser.add_argument("--pmapname", type=str, help="CCDS pmapname", default="")
parser.add_argument( # parser.add_argument(
"--ref-cat", type=str, help="Reference catalog", default="trilegal_093" # "--ref-cat", type=str, help="Reference catalog", default="trilegal_093"
) # )
# submit # submit
parser.add_argument("--submit", action="store_true", help="Push results", default=False) parser.add_argument("--submit", action="store_true", help="Push results", default=False)
# post-processing parameters # post-processing parameters
...@@ -91,7 +90,6 @@ for dag in [ ...@@ -91,7 +90,6 @@ for dag in [
plan_basis=plan_basis, plan_basis=plan_basis,
data_basis=data_basis, data_basis=data_basis,
pmapname=args.pmapname, pmapname=args.pmapname,
ref_cat=args.ref_cat,
) )
print(f"- [{dag}] : {len(this_dag_run_list)} dag_runs") print(f"- [{dag}] : {len(this_dag_run_list)} dag_runs")
dag_run_list.extend(this_dag_run_list) dag_run_list.extend(this_dag_run_list)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment