|
|
|
@ -142,6 +142,7 @@ async def check_updates():
|
|
|
|
|
tag_list = set(tuple(t.decode().split()) for t in await redis.smembers('e621:subs'))
|
|
|
|
|
last_post_version = int((await redis.get('e621:last_version') or b'0').decode())
|
|
|
|
|
post_versions: List[E621PostVersion] = []
|
|
|
|
|
logging.warning(f'Getting post versions from id {last_post_version}')
|
|
|
|
|
for page in count(1):
|
|
|
|
|
post_versions_page = await e621.get_post_versions(last_post_version, page)
|
|
|
|
|
post_versions += post_versions_page
|
|
|
|
|