20
20
valkey = None
21
21
ValkeyError = None
22
22
23
-
24
-
25
23
from .async_pubsub_manager import AsyncPubSubManager
26
24
from .redis_manager import parse_redis_sentinel_url
27
25
@@ -59,7 +57,8 @@ def __init__(self, url='redis://localhost:6379/0', channel='socketio',
59
57
write_only = False , logger = None , redis_options = None ):
60
58
if aioredis is None and valkey is None :
61
59
raise RuntimeError ('Redis package is not installed '
62
- '(Run "pip install redis" or "pip install valkey" '
60
+ '(Run "pip install redis" or '
61
+ '"pip install valkey" '
63
62
'in your virtualenv).' )
64
63
if aioredis and not hasattr (aioredis .Redis , 'from_url' ):
65
64
raise RuntimeError ('Version 2 of aioredis package is required.' )
@@ -74,12 +73,14 @@ def _get_redis_module_and_error(self):
74
73
if schema == 'redis' :
75
74
if aioredis is None or RedisError is None :
76
75
raise RuntimeError ('Redis package is not installed '
77
- '(Run "pip install redis" in your virtualenv).' )
76
+ '(Run "pip install redis" '
77
+ 'in your virtualenv).' )
78
78
return aioredis , RedisError
79
79
if schema == 'valkey' :
80
80
if valkey is None or ValkeyError is None :
81
81
raise RuntimeError ('Valkey package is not installed '
82
- '(Run "pip install valkey" in your virtualenv).' )
82
+ '(Run "pip install valkey" '
83
+ 'in your virtualenv).' )
83
84
return valkey , ValkeyError
84
85
error_msg = f'Unsupported Redis URL schema: { schema } '
85
86
raise ValueError (error_msg )
0 commit comments