diff --git a/rowers/management/commands/processemail.py b/rowers/management/commands/processemail.py index d9ba789c..8a7d758d 100644 --- a/rowers/management/commands/processemail.py +++ b/rowers/management/commands/processemail.py @@ -33,6 +33,7 @@ import rowers.polarstuff as polarstuff import rowers.c2stuff as c2stuff import rowers.rp3stuff as rp3stuff import rowers.stravastuff as stravastuff +import rowers.nkstuff as nkstuff from rowers.opaque import encoder from rowers.models import User,VirtualRace,Workout @@ -213,6 +214,11 @@ class Command(BaseCommand): if user_is_not_basic(r.user): res = rp3stuff.get_rp3_workouts(r) + rowers = Rower.objects.filter(nk_auto_import=True) + for r in rowers: + if user_is_not_basic(r.user): + res = nkstuff.get_nk_workouts(r) + messages = Message.objects.filter(mailbox_id = workoutmailbox.id) message_ids = [m.id for m in messages] attachments = MessageAttachment.objects.filter( diff --git a/rowers/tasks.py b/rowers/tasks.py index 38bbba4c..c9dab841 100644 --- a/rowers/tasks.py +++ b/rowers/tasks.py @@ -3018,9 +3018,12 @@ def handle_nk_async_workout(alldata,userid,nktoken,nkid,delaysec,defaulttimezone conn.close() parkedids = [] - with open('nkblocked.json','r') as nkblocked: - jsondata = json.load(nkblocked) - parkedids = jsondata['ids'] + try: + with open('nkblocked.json','r') as nkblocked: + jsondata = json.load(nkblocked) + parkedids = jsondata['ids'] + except FileNotFoundError: + pass newparkedids = [id for id in parkedids if id != newnkid] with open('nkblocked.json','wt') as nkblocked: