mirror of
https://github.com/flibusta-apps/telegram_files_cache_server.git
synced 2025-12-06 06:35:38 +01:00
Update background tasks
This commit is contained in:
@@ -61,11 +61,10 @@ async def check_books(ctx: dict, *args, **kwargs) -> None: # NOSONAR
|
||||
except httpx.ConnectError:
|
||||
raise Retry(defer=15) # noqa: B904
|
||||
|
||||
for i, page_number in enumerate(range(books_page.total_pages, 0, -1)):
|
||||
for page_number in range(books_page.total_pages, 0, -1):
|
||||
await arq_pool.enqueue_job(
|
||||
"check_books_page",
|
||||
page_number,
|
||||
_defer_by=2 * i,
|
||||
_job_id=f"check_books_page_{page_number}",
|
||||
)
|
||||
|
||||
|
||||
@@ -29,8 +29,9 @@ class WorkerSettings:
|
||||
on_startup = startup
|
||||
on_shutdown = shutdown
|
||||
redis_settings = get_redis_settings()
|
||||
max_jobs = 2
|
||||
max_jobs = 1
|
||||
max_tries = 1
|
||||
job_timeout = 10 * 60
|
||||
job_serializer = msgpack.packb
|
||||
job_deserializer = lambda b: msgpack.unpackb(b, raw=False) # noqa: E731
|
||||
expires_extra_ms = 7 * 24 * 60 * 1000
|
||||
|
||||
Reference in New Issue
Block a user