def cleanup(): cutoffdate = datetime.datetime.now() - datetime.timedelta(days=30) keys = TaskProgress.query(TaskProgress.created < cutoffdate).fetch(keys_only=True) ndb.delete_multi(keys)