From 8dcc40d83acadcae7937cef8838c30a4d91529c3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AD=8F=E8=B1=B9?= Date: Thu, 3 Sep 2020 21:21:16 +0800 Subject: [PATCH] consistent_hash parameter in the send method is incorrect --- channels_redis/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/channels_redis/core.py b/channels_redis/core.py index 84cec2f..5f0e48e 100644 --- a/channels_redis/core.py +++ b/channels_redis/core.py @@ -313,7 +313,7 @@ async def send(self, channel, message): # Pick a connection to the right server - consistent for specific # channels, random for general channels if "!" in channel: - index = self.consistent_hash(channel) + index = self.consistent_hash(channel_non_local_name) else: index = next(self._send_index_generator) async with self.connection(index) as connection: