Private
Public Access
1
0

small improvements in c2import

This commit is contained in:
Sander Roosendaal
2021-02-11 08:24:20 +01:00
parent bc0d34e78c
commit daa92ee3e4
2 changed files with 6 additions and 1 deletions

View File

@@ -196,6 +196,7 @@ def get_c2_workouts(rower,do_async=True):
knownc2ids = uniqify(knownc2ids+tombstones+parkedids)
newids = [c2id for c2id in c2ids if not c2id in knownc2ids]
print(newids,'aap')
newparkedids = uniqify(newids+parkedids)
@@ -203,6 +204,7 @@ def get_c2_workouts(rower,do_async=True):
data = {'ids':newparkedids}
json.dump(data,c2blocked)
counter = 0
for c2id in newids:
if do_async:
res = myqueue(queuehigh,
@@ -211,7 +213,9 @@ def get_c2_workouts(rower,do_async=True):
rower.user.id,
rower.c2token,
c2id,
counter
)
counter = counter+1
else:
workoutid = create_async_workout(alldata,
rower.user,c2id)

View File

@@ -2794,7 +2794,8 @@ def handle_rp3_async_workout(userid,rp3token,rp3id,startdatetime,debug=False,**k
return workoutid
@app.task
def handle_c2_async_workout(alldata,userid,c2token,c2id,debug=False,**kwargs):
def handle_c2_async_workout(alldata,userid,c2token,c2id,delaysec,debug=False,**kwargs):
time.sleep(delaysec)
data = alldata[c2id]
splitdata = None