Skip to content

Commit a8deb3a

Browse files
authored
Add support for unix-sock protocol (#1503)
1 parent 9e42f46 commit a8deb3a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/socketio/async_redis_manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ def __init__(self, url='redis://localhost:6379/0', channel='socketio',
7070
def _get_redis_module_and_error(self):
7171
parsed_url = urlparse(self.redis_url)
7272
schema = parsed_url.scheme.split('+', 1)[0].lower()
73-
if schema == 'redis':
73+
if schema in ['redis', 'unix']:
7474
if aioredis is None or RedisError is None:
7575
raise RuntimeError('Redis package is not installed '
7676
'(Run "pip install redis" '

src/socketio/redis_manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ def initialize(self):
108108
def _get_redis_module_and_error(self):
109109
parsed_url = urlparse(self.redis_url)
110110
schema = parsed_url.scheme.split('+', 1)[0].lower()
111-
if schema == 'redis':
111+
if schema in ['redis', 'unix']:
112112
if redis is None or RedisError is None:
113113
raise RuntimeError('Redis package is not installed '
114114
'(Run "pip install redis" '

0 commit comments

Comments
 (0)