From 8f4417ffc4d30385c5169bde28969e7048974958 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Sun, 17 Nov 2024 13:01:03 +0100 Subject: [PATCH] Fix --- src/core/broker.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/core/broker.py b/src/core/broker.py index 9d479f3..58ee1e7 100644 --- a/src/core/broker.py +++ b/src/core/broker.py @@ -5,13 +5,11 @@ from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend from core.config import config -broker = ListQueueBroker( - url=config.REDIS_URI, - result_backend=RedisAsyncResultBackend( +broker = ListQueueBroker(url=config.REDIS_URI) \ + .with_result_backend(RedisAsyncResultBackend( redis_url=config.REDIS_URI, result_ex_time=60 * 60 * 24 * 7, - ), -) + )) scheduler = TaskiqScheduler(