Skip to content

Commit 8dcc40d

Browse files
魏豹carltongibson
authored andcommitted
consistent_hash parameter in the send method is incorrect
1 parent 1d8db66 commit 8dcc40d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

channels_redis/core.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ async def send(self, channel, message):
313313
# Pick a connection to the right server - consistent for specific
314314
# channels, random for general channels
315315
if "!" in channel:
316-
index = self.consistent_hash(channel)
316+
index = self.consistent_hash(channel_non_local_name)
317317
else:
318318
index = next(self._send_index_generator)
319319
async with self.connection(index) as connection:

0 commit comments

Comments
 (0)