Loading csst_dag/cli/run.py +5 −3 Original line number Diff line number Diff line Loading @@ -8,6 +8,7 @@ Example python -m csst_dag.cli.run -h python -m csst_dag.cli.run \ --dags csst-msc-l1-mbi \ --dataset=csst-msc-c9-25sqdeg-v3 \ --instrument=MSC \ --obs-type=WIDE \ Loading @@ -21,7 +22,8 @@ python -m csst_dag.cli.run \ --ref-cat=trilegal_093 # 25平方度宽场 python -m csst_dag.cli.csst_msc_l1 \ python -m csst_dag.cli.run \ --dags csst-msc-l1-mbi \ --dataset=csst-msc-c9-25sqdeg-v3 \ --instrument=MSC \ --obs-type=WIDE \ Loading @@ -42,7 +44,7 @@ import joblib from csst_dag import CSST_DAGS, Dispatcher, BaseDAG, dfs parser = argparse.ArgumentParser( description="Scheduler for CSST MSC L1 pipeline.", description="Scheduler for CSST L1 pipeline.", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) Loading Loading @@ -120,7 +122,7 @@ print(f"{len(plan_basis)} plan basis, {len(data_basis)} data basis found") # generate DAG group run dag_group_run = BaseDAG.gen_dag_group_run( dag_group="csst-msc-l1", dag_group="csst-l1-pipeline", batch_id=args.batch_id, priority=args.priority, ) Loading Loading
csst_dag/cli/run.py +5 −3 Original line number Diff line number Diff line Loading @@ -8,6 +8,7 @@ Example python -m csst_dag.cli.run -h python -m csst_dag.cli.run \ --dags csst-msc-l1-mbi \ --dataset=csst-msc-c9-25sqdeg-v3 \ --instrument=MSC \ --obs-type=WIDE \ Loading @@ -21,7 +22,8 @@ python -m csst_dag.cli.run \ --ref-cat=trilegal_093 # 25平方度宽场 python -m csst_dag.cli.csst_msc_l1 \ python -m csst_dag.cli.run \ --dags csst-msc-l1-mbi \ --dataset=csst-msc-c9-25sqdeg-v3 \ --instrument=MSC \ --obs-type=WIDE \ Loading @@ -42,7 +44,7 @@ import joblib from csst_dag import CSST_DAGS, Dispatcher, BaseDAG, dfs parser = argparse.ArgumentParser( description="Scheduler for CSST MSC L1 pipeline.", description="Scheduler for CSST L1 pipeline.", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) Loading Loading @@ -120,7 +122,7 @@ print(f"{len(plan_basis)} plan basis, {len(data_basis)} data basis found") # generate DAG group run dag_group_run = BaseDAG.gen_dag_group_run( dag_group="csst-msc-l1", dag_group="csst-l1-pipeline", batch_id=args.batch_id, priority=args.priority, ) Loading