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
2 people authored and yusk committed Feb 25, 2023
1 parent 4cfc2ea commit 4a4d8c0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions channels_redis/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@

import msgpack
from redis import asyncio as aioredis
from copy import deepcopy
from channels.exceptions import ChannelFull
from channels.layers import BaseChannelLayer

Expand Down Expand Up @@ -132,14 +131,15 @@ 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),
**host_kwargs
**host
)
else:
return aioredis.ConnectionPool(**host)
Expand Down

0 comments on commit 4a4d8c0

Please sign in to comment.