flibusta-apps/telegram_files_cache_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_cache_server.git synced 2025-12-06 14:45:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-01-01 20:53:52 +01:00
parent 0644122364
commit 3ed43b002e
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/core/arq_pool.py
View File

@@ -1,4 +1,5 @@
from arq.connections import create_pool, RedisSettings, ArqRedis from arq.connections import create_pool, RedisSettings, ArqRedis
import msgpack
from core.config import env_config from core.config import env_config
@@ -12,4 +13,8 @@ def get_redis_settings() -> RedisSettings:
async def get_arq_pool() -> ArqRedis: async def get_arq_pool() -> ArqRedis:
return await create_pool(get_redis_settings()) return await create_pool(
get_redis_settings(),
job_serializer=msgpack.packb, # type: ignore
job_deserializer=lambda b: msgpack.unpackb(b, raw=False), # noqa: E731
)