From 3ed43b002eeda5a170e0ac672e09a6317ba82762 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Sun, 1 Jan 2023 20:53:52 +0100 Subject: [PATCH] Fix --- src/core/arq_pool.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/core/arq_pool.py b/src/core/arq_pool.py index e5de84d..22dac91 100644 --- a/src/core/arq_pool.py +++ b/src/core/arq_pool.py @@ -1,4 +1,5 @@ from arq.connections import create_pool, RedisSettings, ArqRedis +import msgpack from core.config import env_config @@ -12,4 +13,8 @@ def get_redis_settings() -> RedisSettings: 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 + )