diff --git a/src/app/services/cache_updater.py b/src/app/services/cache_updater.py index 0a22735..0698d07 100644 --- a/src/app/services/cache_updater.py +++ b/src/app/services/cache_updater.py @@ -48,7 +48,11 @@ async def check_books_page(ctx, page_number: int) -> None: for file_type in book.available_types: if file_type not in cached_files_map[book.id]: await arq_pool.enqueue_job( - "cache_file_by_book_id", book.id, file_type, by_request=False + "cache_file_by_book_id", + book.id, + file_type, + by_request=False, + _job_id=f"cache_file_by_book_id_{book.id}_{file_type}", ) @@ -60,7 +64,12 @@ async def check_books(ctx: dict, *args, **kwargs) -> None: # NOSONAR raise Retry(defer=15) 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) + await arq_pool.enqueue_job( + "check_books_page", + page_number, + _defer_by=2 * i, + _job_id=f"check_books_page_{page_number}", + ) async def cache_file(book: Book, file_type: str) -> Optional[CachedFile]: diff --git a/src/app/views.py b/src/app/views.py index 5731849..64104b6 100644 --- a/src/app/views.py +++ b/src/app/views.py @@ -128,7 +128,7 @@ async def create_or_update_cached_file(data: CreateCachedFile): @router.post("/update_cache") async def update_cache(request: Request): arq_pool: ArqRedis = request.app.state.arq_pool - await arq_pool.enqueue_job("check_books") + await arq_pool.enqueue_job("check_books", _job_id="check_books") return "Ok!"