File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -67,7 +67,7 @@ async def _acquire_master_conn(self) -> AsyncIterator[_Redis]:
67
67
68
68
69
69
class PubSubSentinelBroker (BaseSentinelBroker ):
70
- """Broker that works with Redis and broadcasts tasks to all workers."""
70
+ """Broker that works with Sentinel and broadcasts tasks to all workers."""
71
71
72
72
async def kick (self , message : BrokerMessage ) -> None :
73
73
"""
Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ async def test_pub_sub_sentinel_broker(
184
184
redis_sentinel_master_name : str ,
185
185
) -> None :
186
186
"""
187
- Test that messages are published and read correctly by PubSubBroker .
187
+ Test that messages are published and read correctly by PubSubSentinelBroker .
188
188
189
189
We create two workers that listen and send a message to them.
190
190
Expect both workers to receive the same message we sent.
You can’t perform that action at this time.
0 commit comments