Skip to content

Commit

Permalink
Update channels_redis/core.py
Browse files Browse the repository at this point in the history
Co-authored-by: Devid <[email protected]>
  • Loading branch information
techblack and sevdog authored Feb 25, 2023
1 parent 4cfc2ea commit bdcbbec
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions channels_redis/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -132,10 +132,11 @@ def create_pool(self, index):
if "address" in host:
return aioredis.ConnectionPool.from_url(host["address"])
elif "master_name" in host:
host_kwargs = deepcopy(host)
sentinels = host_kwargs.pop("sentinels")
master_name = host_kwargs.pop("master_name")
sentinel_kwargs = host_kwargs.pop("sentinel_kwargs", None)
# copy host dict to prevent original one from being modified
host= host.copy()
sentinels = host.pop("sentinels")
master_name = host.pop("master_name")
sentinel_kwargs = host.pop("sentinel_kwargs", None)
return aioredis.sentinel.SentinelConnectionPool(
master_name,
aioredis.sentinel.Sentinel(sentinels, sentinel_kwargs=sentinel_kwargs),
Expand Down

0 comments on commit bdcbbec

Please sign in to comment.