1- from typing import Any , AsyncGenerator , Callable , Optional , TypeVar
1+ from typing import Any , AsyncGenerator , Optional , TypeVar
22
33from redis .asyncio import RedisCluster
44from taskiq .abc .broker import AsyncBroker
@@ -14,7 +14,6 @@ class BaseRedisClusterBroker(AsyncBroker):
1414 def __init__ (
1515 self ,
1616 url : str ,
17- task_id_generator : Optional [Callable [[], str ]] = None ,
1817 result_backend : Optional [AsyncResultBackend [_T ]] = None ,
1918 queue_name : str = "taskiq" ,
2019 max_connection_pool_size : int = 2 ** 31 ,
@@ -24,16 +23,12 @@ def __init__(
2423 Constructs a new broker.
2524
2625 :param url: url to redis.
27- :param task_id_generator: custom task_id generator.
2826 :param result_backend: custom result backend.
2927 :param queue_name: name for a list in redis.
3028 :param max_connection_pool_size: maximum number of connections in pool.
3129 :param connection_kwargs: additional arguments for aio-redis ConnectionPool.
3230 """
33- super ().__init__ (
34- result_backend = result_backend ,
35- task_id_generator = task_id_generator ,
36- )
31+ super ().__init__ (result_backend = result_backend )
3732
3833 self .redis : RedisCluster [bytes ] = RedisCluster .from_url (
3934 url = url ,
0 commit comments