This commit is contained in:
2024-11-17 13:01:03 +01:00
parent 203169a9cc
commit 8f4417ffc4

View File

@@ -5,13 +5,11 @@ from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend
from core.config import config from core.config import config
broker = ListQueueBroker( broker = ListQueueBroker(url=config.REDIS_URI) \
url=config.REDIS_URI, .with_result_backend(RedisAsyncResultBackend(
result_backend=RedisAsyncResultBackend(
redis_url=config.REDIS_URI, redis_url=config.REDIS_URI,
result_ex_time=60 * 60 * 24 * 7, result_ex_time=60 * 60 * 24 * 7,
), ))
)
scheduler = TaskiqScheduler( scheduler = TaskiqScheduler(