From a8deb3a8f3ee51d75c124157efa7fc9289fd592b Mon Sep 17 00:00:00 2001 From: Darren Chang Date: Thu, 2 Oct 2025 17:19:21 +0800 Subject: [PATCH] Add support for unix-sock protocol (#1503) --- src/socketio/async_redis_manager.py | 2 +- src/socketio/redis_manager.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/socketio/async_redis_manager.py b/src/socketio/async_redis_manager.py index 4f9e326..b099d9e 100644 --- a/src/socketio/async_redis_manager.py +++ b/src/socketio/async_redis_manager.py @@ -70,7 +70,7 @@ class AsyncRedisManager(AsyncPubSubManager): # pragma: no cover def _get_redis_module_and_error(self): parsed_url = urlparse(self.redis_url) schema = parsed_url.scheme.split('+', 1)[0].lower() - if schema == 'redis': + if schema in ['redis', 'unix']: if aioredis is None or RedisError is None: raise RuntimeError('Redis package is not installed ' '(Run "pip install redis" ' diff --git a/src/socketio/redis_manager.py b/src/socketio/redis_manager.py index 4f701b9..13d2022 100644 --- a/src/socketio/redis_manager.py +++ b/src/socketio/redis_manager.py @@ -108,7 +108,7 @@ class RedisManager(PubSubManager): # pragma: no cover def _get_redis_module_and_error(self): parsed_url = urlparse(self.redis_url) schema = parsed_url.scheme.split('+', 1)[0].lower() - if schema == 'redis': + if schema in ['redis', 'unix']: if redis is None or RedisError is None: raise RuntimeError('Redis package is not installed ' '(Run "pip install redis" '