another attempt
This commit is contained in:
@@ -1219,10 +1219,45 @@ def dataprep(rowdatadf,id=0,bands=True,barchart=True,otwpower=True,
|
||||
|
||||
data = data.replace([-np.inf,np.inf],np.nan)
|
||||
data = data.fillna(method='ffill')
|
||||
|
||||
|
||||
# write data if id given
|
||||
if id != 0:
|
||||
data['workoutid'] = id
|
||||
|
||||
data = data[['averageforce',
|
||||
'cumdist',
|
||||
'distance',
|
||||
'distanceperstroke',
|
||||
'driveenergy',
|
||||
'drivelength',
|
||||
'drivespeed',
|
||||
'forceratio',
|
||||
'fpace',
|
||||
'ftime',
|
||||
'hr',
|
||||
'pace',
|
||||
'peakforce',
|
||||
'power',
|
||||
'spm',
|
||||
'time',
|
||||
'velo',
|
||||
'workoutstate',
|
||||
'x_right',
|
||||
'wash',
|
||||
'catch',
|
||||
'slip',
|
||||
'finish',
|
||||
'peakforceangle',
|
||||
'totalangle',
|
||||
'effectiveangle',
|
||||
'efficiency',
|
||||
'ergpace',
|
||||
'nowindpace',
|
||||
'equivergpower',
|
||||
'fergpace',
|
||||
'fnowindpace',
|
||||
'workoutid']]
|
||||
|
||||
if debug:
|
||||
engine = create_engine(database_url_debug, echo=False)
|
||||
else:
|
||||
|
||||
@@ -286,6 +286,7 @@ def myqueue(queue,function,*args,**kwargs):
|
||||
job_id = str(uuid.uuid4())
|
||||
kwargs['job_id'] = job_id
|
||||
kwargs['jobkey'] = job_id
|
||||
kwargs['timeout'] = 3600
|
||||
|
||||
job = queue.enqueue(function,*args,**kwargs)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user