From a9c57e3c7c32471c3caf6a40ea579e07c535b773 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Wed, 10 Aug 2022 13:11:15 +0300 Subject: [PATCH] Add defer for check_books_page task --- src/app/services/cache_updater.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/app/services/cache_updater.py b/src/app/services/cache_updater.py index 62fff01..52b9668 100644 --- a/src/app/services/cache_updater.py +++ b/src/app/services/cache_updater.py @@ -55,8 +55,8 @@ async def check_books(ctx: dict, *args, **kwargs) -> None: # NOSONAR except httpx.ConnectError: raise Retry(defer=15) - for page_number in range(books_page.total_pages, 0, -1): - await arq_pool.enqueue_job("check_books_page", page_number) + for i, page_number in enumerate(range(books_page.total_pages, 0, -1)): + await arq_pool.enqueue_job("check_books_page", page_number, _defer_by=2 * i) async def cache_file(book: Book, file_type: str) -> Optional[CachedFile]: