This commit is contained in:
2023-01-01 21:42:37 +01:00
parent 25ba409be7
commit be43f588d4

View File

@@ -115,7 +115,6 @@ async def cache_file(
chat_id=upload_data.data["chat_id"], chat_id=upload_data.data["chat_id"],
) )
if by_request:
return cached_file return cached_file
@@ -143,7 +142,10 @@ async def cache_file_by_book_id(
try: try:
try: try:
async with lock: async with lock:
return await cache_file(book, file_type, by_request) result = await cache_file(book, file_type, by_request)
if by_request:
return result
except LockError: except LockError:
raise Retry(defer=timedelta(minutes=15).seconds * random.random()) raise Retry(defer=timedelta(minutes=15).seconds * random.random())
except Retry as e: except Retry as e: