Skip to content

Commit d4189c6

Browse files
pinguingmanzazymking
authored andcommitted
remove result_backend from BaseRedisClusterBroker
1 parent 5c3080d commit d4189c6

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

taskiq_redis/redis_cluster_broker.py

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,16 @@
1-
from typing import Any, AsyncGenerator, Optional, TypeVar
1+
from typing import Any, AsyncGenerator
22

33
from redis.asyncio import RedisCluster
44
from taskiq.abc.broker import AsyncBroker
5-
from taskiq.abc.result_backend import AsyncResultBackend
65
from taskiq.message import BrokerMessage
76

8-
_T = TypeVar("_T")
9-
107

118
class BaseRedisClusterBroker(AsyncBroker):
129
"""Base broker that works with Redis Cluster."""
1310

1411
def __init__(
1512
self,
1613
url: str,
17-
result_backend: Optional[AsyncResultBackend[_T]] = None,
1814
queue_name: str = "taskiq",
1915
max_connection_pool_size: int = 2**31,
2016
**connection_kwargs: Any,
@@ -23,12 +19,11 @@ def __init__(
2319
Constructs a new broker.
2420
2521
:param url: url to redis.
26-
:param result_backend: custom result backend.
2722
:param queue_name: name for a list in redis.
2823
:param max_connection_pool_size: maximum number of connections in pool.
2924
:param connection_kwargs: additional arguments for aio-redis ConnectionPool.
3025
"""
31-
super().__init__(result_backend=result_backend)
26+
super().__init__()
3227

3328
self.redis: RedisCluster[bytes] = RedisCluster.from_url(
3429
url=url,

0 commit comments

Comments
 (0)