expiry time
This commit is contained in:
@@ -576,17 +576,19 @@ def setcp(workout, background=False, recurrance=True):
|
||||
cpvalues = pl.Series(np.array(response.power))
|
||||
powermean = response.avgpower
|
||||
|
||||
df = pl.DataFrame({
|
||||
'delta': delta,
|
||||
'cp': cpvalues,
|
||||
'id': workout.id,
|
||||
})
|
||||
|
||||
df = df.drop_nulls()
|
||||
|
||||
with gzip.open(filename, 'w') as f:
|
||||
df.write_parquet(f)
|
||||
try:
|
||||
df = pl.DataFrame({
|
||||
'delta': delta,
|
||||
'cp': cpvalues,
|
||||
'id': workout.id,
|
||||
})
|
||||
|
||||
df = df.drop_nulls()
|
||||
|
||||
with gzip.open(filename, 'w') as f:
|
||||
df.write_parquet(f)
|
||||
except:
|
||||
return False
|
||||
|
||||
#df.to_parquet(filename, engine='fastparquet', compression='GZIP')
|
||||
|
||||
|
||||
Reference in New Issue
Block a user