filter_basis: sort via obs_id

csst_dag/dag/_base_dag.py

@@ -78,6 +78,8 @@ class BaseDAG:
             keys=self.pattern.colnames,
             join_type="inner",
         )
+        # sort via obs_id
+        filtered_data_basis.sort(keys=["dataset", "obs_id"])
         if len(filtered_data_basis) == 0:
             return plan_basis[:0], filtered_data_basis
         u_data_basis = table.unique(filtered_data_basis["dataset", "obs_id"])