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

update msc cli

parent 70c2067b
# Process a dataset, given # Process a dataset, given
# - project_id = "none" # - project_id = "none"
# - obs_type = "*" # - obs_type = "*"
from csst_dag.dag import dags from csst_dag.dag import CsstDAG
import argparse import argparse
# python -m csst_dag.trigger.csst-msc-l1-mbi -h # python -m csst_dag.trigger.csst-msc-l1-mbi -h
...@@ -30,8 +30,8 @@ DAG_LOOP_MAP = { ...@@ -30,8 +30,8 @@ DAG_LOOP_MAP = {
for obs_type, dag_ids in DAG_LOOP_MAP.items(): for obs_type, dag_ids in DAG_LOOP_MAP.items():
print(f"* Processing {obs_type}") print(f"* Processing {obs_type}")
for dag_id in dag_ids: for dag_id in dag_ids:
print(f" - {dag_id} ··· ", end="") print(f" - Scheduling `{dag_id}` -> ", end="")
dag = dags.get_dag(dag_id=dag_id) dag = CsstDAG.get_dag(dag_id=dag_id)
msgs = dag.schedule( msgs = dag.schedule(
dataset=args.dataset, dataset=args.dataset,
obs_type=args.obs_type, obs_type=args.obs_type,
...@@ -41,4 +41,4 @@ for obs_type, dag_ids in DAG_LOOP_MAP.items(): ...@@ -41,4 +41,4 @@ for obs_type, dag_ids in DAG_LOOP_MAP.items():
final_prc_status=-2, final_prc_status=-2,
demo=True, demo=True,
) )
print(f"{len(msgs)} tasks scheduled.") print(f"{len(msgs)} tasks.")
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