1
- from typing import Any , AsyncGenerator , Callable , Optional , TypeVar
1
+ from typing import Any , AsyncGenerator , Optional , TypeVar
2
2
3
3
from redis .asyncio import RedisCluster
4
4
from taskiq .abc .broker import AsyncBroker
@@ -14,7 +14,6 @@ class BaseRedisClusterBroker(AsyncBroker):
14
14
def __init__ (
15
15
self ,
16
16
url : str ,
17
- task_id_generator : Optional [Callable [[], str ]] = None ,
18
17
result_backend : Optional [AsyncResultBackend [_T ]] = None ,
19
18
queue_name : str = "taskiq" ,
20
19
max_connection_pool_size : int = 2 ** 31 ,
@@ -24,16 +23,12 @@ def __init__(
24
23
Constructs a new broker.
25
24
26
25
:param url: url to redis.
27
- :param task_id_generator: custom task_id generator.
28
26
:param result_backend: custom result backend.
29
27
:param queue_name: name for a list in redis.
30
28
:param max_connection_pool_size: maximum number of connections in pool.
31
29
:param connection_kwargs: additional arguments for aio-redis ConnectionPool.
32
30
"""
33
- super ().__init__ (
34
- result_backend = result_backend ,
35
- task_id_generator = task_id_generator ,
36
- )
31
+ super ().__init__ (result_backend = result_backend )
37
32
38
33
self .redis : RedisCluster [bytes ] = RedisCluster .from_url (
39
34
url = url ,
0 commit comments