From db1104aeadb4e2ae9273d1903741b7f98a525d85 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Sat, 20 May 2023 21:36:38 +0200 Subject: [PATCH] Fix --- src/app/services/cache_updater.py | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/src/app/services/cache_updater.py b/src/app/services/cache_updater.py index 9bc8ef0..5a7d975 100644 --- a/src/app/services/cache_updater.py +++ b/src/app/services/cache_updater.py @@ -125,13 +125,10 @@ async def cache_file_by_book_id( f"{book_id}_{file_type}", blocking_timeout=5, thread_local=False ) - try: - async with lock: - result = await cache_file(book, file_type) - except Exception as e: - if by_request: - return None - raise Retry from e + if await lock.locked() and not by_request: + raise Retry + + result = await cache_file(book, file_type) if by_request: return result