csst_dag/dag/_dispatcher.py

@@ -170,13 +170,15 @@ 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
+                    # count effective detectors of this instrument
+                    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 {_}")
@@ -464,6 +466,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(