BFX

saqc/funcs/proc_functions.py

@@ -778,7 +778,9 @@ def proc_projectFlags(data, field, flagger, method, source, freq=None, to_drop=N
         # reinsert drops
         target_flagscol = target_flagscol.reindex(target_flagscol.index.join(target_flagscol_drops.index, how="outer"))
         target_flagscol.loc[target_flagscol_drops.index] = target_flagscol_drops.values
+
         for meta_key in target_metacols.keys():
+            target_metadrops = target_metacols[meta_key][drop_mask]
             target_metacols[meta_key].drop(drop_mask[drop_mask].index, inplace=True)
             meta_merged = pd.merge_asof(
                 metacols[meta_key],
@@ -791,7 +793,11 @@ def proc_projectFlags(data, field, flagger, method, source, freq=None, to_drop=N
             )
             meta_merged.dropna(subset=["pre_index"], inplace=True)
             meta_merged = meta_merged.set_index(["pre_index"]).squeeze()
+            # reinsert drops
             target_metacols[meta_key][replacement_mask[replacement_mask].index] = meta_merged[replacement_mask]
+            target_metacols[meta_key] = target_metacols[meta_key].reindex(
+                target_metacols[meta_key].index.join(target_metadrops.index, how="outer"))
+            target_metacols[meta_key].loc[target_metadrops.index] = target_metadrops.values
 
     flagger = flagger.setFlags(field, flag=target_flagscol, with_extra=True, **target_metacols)
     return data, flagger