Loading csst_dag/cli/msc.py +2 −2 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ if args.obs_type: DAG_MAP = {args.obs_type: DAG_MAP[args.obs_type]} for obs_type, dags in DAG_MAP.items(): print(f"* Processing {obs_type}") print(f"* Processing `{obs_type}`") for this_dag in dags: print(f" - Scheduling `{this_dag}` -> ", end="") dag = CsstDAGs().get(this_dag) Loading csst_dag/dag/l1.py +5 −2 Original line number Diff line number Diff line Loading @@ -125,7 +125,11 @@ class GeneralL1DAG(BaseDAG): priority=priority, ) if demo: print(json.dumps(dag_group_run, indent=4)) # print(json.dumps(dag_group_run, indent=4)) # try single-lined json verbose print( " - " + json.dumps(dag_group_run, indent=None, separators=(",", ":")) ) # find level0 data records recs = level0.find( Loading Loading @@ -159,7 +163,6 @@ class GeneralL1DAG(BaseDAG): obs_group=obs_group, obs_id=this_rec["obs_id"], **additional_keys, **kwargs, ) if demo: print(json.dumps(this_dag_run, indent=4)) Loading Loading
csst_dag/cli/msc.py +2 −2 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ if args.obs_type: DAG_MAP = {args.obs_type: DAG_MAP[args.obs_type]} for obs_type, dags in DAG_MAP.items(): print(f"* Processing {obs_type}") print(f"* Processing `{obs_type}`") for this_dag in dags: print(f" - Scheduling `{this_dag}` -> ", end="") dag = CsstDAGs().get(this_dag) Loading
csst_dag/dag/l1.py +5 −2 Original line number Diff line number Diff line Loading @@ -125,7 +125,11 @@ class GeneralL1DAG(BaseDAG): priority=priority, ) if demo: print(json.dumps(dag_group_run, indent=4)) # print(json.dumps(dag_group_run, indent=4)) # try single-lined json verbose print( " - " + json.dumps(dag_group_run, indent=None, separators=(",", ":")) ) # find level0 data records recs = level0.find( Loading Loading @@ -159,7 +163,6 @@ class GeneralL1DAG(BaseDAG): obs_group=obs_group, obs_id=this_rec["obs_id"], **additional_keys, **kwargs, ) if demo: print(json.dumps(this_dag_run, indent=4)) Loading