|
|
|
@ -122,8 +122,9 @@ async def check_updates():
|
|
|
|
|
for tl_idx in range(0, len(tag_list), 40):
|
|
|
|
|
tags = ' '.join(f'~{tag}' for tag in tag_list[tl_idx: tl_idx + 40])
|
|
|
|
|
logging.warning(tags)
|
|
|
|
|
posts = []
|
|
|
|
|
for page in range(1, 11):
|
|
|
|
|
posts = await e621.get_posts(tags, page)
|
|
|
|
|
posts.extend(await e621.get_posts(tags, page))
|
|
|
|
|
if not posts:
|
|
|
|
|
return
|
|
|
|
|
already_sent: List = await redis.smismember('e621:sent', [p.id for p in posts])
|
|
|
|
|