flibusta-apps/telegram_files_cache_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_cache_server.git synced 2025-12-06 14:45:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-08-06 15:59:02 +02:00
parent 2f2dc0d165
commit e4f022face
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/app/services/cache_updater.py
View File

@@ -32,10 +32,13 @@ class FileTypeNotAllowed(Exception):
@broker.task @broker.task
async def check_books_page( async def check_books_page(
page_number: int, uploaded_gte: date, uploaded_lte: date page_number: int, uploaded_gte: str, uploaded_lte: str
) -> bool: ) -> bool:
page = await get_books( page = await get_books(
page_number, PAGE_SIZE, uploaded_gte=uploaded_gte, uploaded_lte=uploaded_lte page_number,
PAGE_SIZE,
uploaded_gte=date.fromisoformat(uploaded_gte),
uploaded_lte=date.fromisoformat(uploaded_lte),
) )
object_ids = [book.id for book in page.items] object_ids = [book.id for book in page.items]
@@ -69,7 +72,9 @@ async def check_books(*args, **kwargs) -> bool:
for page_number in range(1, books_page.pages + 1): for page_number in range(1, books_page.pages + 1):
await check_books_page.kiq( await check_books_page.kiq(
page_number, uploaded_gte=uploaded_gte, uploaded_lte=uploaded_lte page_number,
uploaded_gte=uploaded_gte.isoformat(),
uploaded_lte=uploaded_lte.isoformat(),
) )
return True return True