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

add ref_cat argument

parent 1fff4a73
...@@ -46,9 +46,9 @@ parser.add_argument("--batch-id", type=str, help="Batch ID", default="test-batch ...@@ -46,9 +46,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
...@@ -96,6 +96,7 @@ for dag in [ ...@@ -96,6 +96,7 @@ 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,
force_success=args.force, force_success=args.force,
) )
this_dag_run_list = [this_task["dag_run"] for this_task in this_task_list if this_task["dag_run"] is not None] this_dag_run_list = [this_task["dag_run"] for this_task in this_task_list if this_task["dag_run"] is not None]
......
...@@ -131,6 +131,7 @@ for dag in [ ...@@ -131,6 +131,7 @@ 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,
force_success=args.force, force_success=args.force,
) )
this_dag_run_list = [this_task["dag_run"] for this_task in this_task_list if this_task["dag_run"] is not None] this_dag_run_list = [this_task["dag_run"] for this_task in this_task_list if this_task["dag_run"] is not None]
......
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