diff --git a/rowers/dataprep.py b/rowers/dataprep.py index 951b287c..543b3872 100644 --- a/rowers/dataprep.py +++ b/rowers/dataprep.py @@ -1037,6 +1037,8 @@ def fetchcp_new(rower,workouts): if len(data)>1: df = pd.concat(data,axis=0) + print(df) + df = df = df[df['cp'] == df.groupby(['delta'])['cp'].transform('max')] @@ -1076,7 +1078,7 @@ def setcp(workout,background=False): df.to_parquet(filename,engine='fastparquet',compression='GZIP') return df,delta,cpvalues - return pd.DataFrame(),pd.Series(),pd.Series() + return pd.DataFrame({'delta':[],'cp':[]}),pd.Series(),pd.Series() def fetchcp(rower,theworkouts,table='cpdata'):