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]:
6767
6868
6969class 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."""
7171
7272 async def kick (self , message : BrokerMessage ) -> None :
7373 """
Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ async def test_pub_sub_sentinel_broker(
184184 redis_sentinel_master_name : str ,
185185) -> None :
186186 """
187- Test that messages are published and read correctly by PubSubBroker .
187+ Test that messages are published and read correctly by PubSubSentinelBroker .
188188
189189 We create two workers that listen and send a message to them.
190190 Expect both workers to receive the same message we sent.
You can’t perform that action at this time.
0 commit comments