From 04c2a582b927b732667261f1e0aef45be6ce6b30 Mon Sep 17 00:00:00 2001 From: Ryan Barrett Date: Sun, 5 Feb 2023 08:17:11 -0800 Subject: [PATCH] migrate_activity_to_object: resume from latest_updated --- scripts/migrate_activity_to_object.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/scripts/migrate_activity_to_object.py b/scripts/migrate_activity_to_object.py index 5947cee..c6b56a4 100644 --- a/scripts/migrate_activity_to_object.py +++ b/scripts/migrate_activity_to_object.py @@ -31,10 +31,19 @@ with open('seen.json') as f: def run(): + global latest_updated + query = Activity.query().order(Activity.key) if len(sys.argv) > 1: print(f'Starting at {sys.argv[1]}') query = query.filter(Activity.key >= ndb.Key(Activity, sys.argv[1])) + elif latest_updated: + print(f'Starting at {latest_updated}') + query = list(Activity.query(Activity.updated > latest_updated)) + query.sort(key=lambda a: a.key) + # print(query.filter(Activity.updated > latest_updated).count()) + # print(len(query)) + # sys.exit() else: print('Starting at the beginning') @@ -143,7 +152,6 @@ def run(): if a.updated > obj.updated: obj.updated = a.updated - global latest_updated if a.updated > latest_updated: latest_updated = a.updated