diff --git a/saqc/funcs/drift.py b/saqc/funcs/drift.py index a84ddf6573d13a92e1b1925fd5a29505d938d249..99c45ba8321b7f0db6eb10546be9c23655998209 100644 --- a/saqc/funcs/drift.py +++ b/saqc/funcs/drift.py @@ -389,7 +389,7 @@ def correctExponentialDrift(data: DictOfSeries, field: str, flagger: BaseFlagger drift_frame.loc[maint_data.values[k] : pd.Timestamp(maint_data.index[k + 1]), "drift_group"] = k drift_grouper = drift_frame.groupby("drift_group") # define target values for correction - shift_targets = shift(-1) + shift_targets = drift_grouper.aggregate(lambda x: x[:cal_mean].mean()).shift(-1) for k, group in drift_grouper: dataSeries = group[to_correct.name]