diff --git a/rowers/dataroutines.py b/rowers/dataroutines.py index 154d75f8..3acdf49e 100644 --- a/rowers/dataroutines.py +++ b/rowers/dataroutines.py @@ -2204,26 +2204,27 @@ def dataplep(rowdatadf, id=0, inboard=0.88, forceunit='lbs', bands=True, barchar if windowsize <= 3: windowsize = 5 + try: - df.with_columns( + df = df.with_columns( (pl.col(" Cadence (stokes/min)").map_batches(lambda x: savgol_filter(x.to_numpy(), windowsize, 3)).explode() ).alias(" Cadence (stokes/min)")) - except ComputeError: + except ComputeError as e: pass try: - df.with_columns( + df = df.with_columns( (pl.col(" DriveLength (meters)").map_batches(lambda x: savgol_filter(x.to_numpy(), windowsize, 3)).explode() ).alias(" DriveLength (meters)")) except ComputeError: pass try: - df.with_columns( + df = df.with_columns( (pl.col(" HRCur (bpm)").map_batches(lambda x: savgol_filter(x.to_numpy(), windowsize, 3)).explode() ).alias(" HRCur (bpm)")) except ComputeError: pass try: - df.with_columns((pl.col("forceratio").map_batches(lambda x: savgol_filter(x.to_numpy(), windowsize, 3)).explode()).alias("forceratio")) + df = df.with_columns((pl.col("forceratio").map_batches(lambda x: savgol_filter(x.to_numpy(), windowsize, 3)).explode()).alias("forceratio")) except ComputeError: pass