Loading csst_dag/dag/_dispatcher.py +5 −2 Original line number Diff line number Diff line Loading @@ -170,13 +170,14 @@ class Dispatcher: # plan basis / obsid basis try: for _ in qr.data: if _["instrument"] == "HSTDM": this_instrument = _["instrument"] if this_instrument == "HSTDM": if _["params"]["detector"] == "SIS12": this_n_file = len(_["params"]["exposure_start"]) * 2 else: this_n_file = len(_["params"]["exposure_start"]) else: this_n_file = 1 this_n_file = len(csst[this_instrument].effective_detector_names) _["n_file"] = this_n_file except KeyError: print(f"`n_epec_frame` is not found in {_}") Loading Loading @@ -464,6 +465,8 @@ class Dispatcher: if len(plan_basis) == 0 or len(data_basis) == 0: return [] obsid_basis = data_basis.group_by([""]) # unique obsid u_obsid = table.unique(data_basis["dataset", "obs_id"]) relevant_plan = table.join( Loading Loading
csst_dag/dag/_dispatcher.py +5 −2 Original line number Diff line number Diff line Loading @@ -170,13 +170,14 @@ class Dispatcher: # plan basis / obsid basis try: for _ in qr.data: if _["instrument"] == "HSTDM": this_instrument = _["instrument"] if this_instrument == "HSTDM": if _["params"]["detector"] == "SIS12": this_n_file = len(_["params"]["exposure_start"]) * 2 else: this_n_file = len(_["params"]["exposure_start"]) else: this_n_file = 1 this_n_file = len(csst[this_instrument].effective_detector_names) _["n_file"] = this_n_file except KeyError: print(f"`n_epec_frame` is not found in {_}") Loading Loading @@ -464,6 +465,8 @@ class Dispatcher: if len(plan_basis) == 0 or len(data_basis) == 0: return [] obsid_basis = data_basis.group_by([""]) # unique obsid u_obsid = table.unique(data_basis["dataset", "obs_id"]) relevant_plan = table.join( Loading