Rifqi Hafizuddin commited on
Commit ·
0810be5
1
Parent(s): 81e5fe7
/fix redis connection code for general redis connection
Browse files
src/db/redis/connection.py
CHANGED
|
@@ -3,11 +3,15 @@
|
|
| 3 |
import redis.asyncio as redis
|
| 4 |
from src.config.settings import settings
|
| 5 |
|
|
|
|
|
|
|
|
|
|
|
|
|
| 6 |
redis_client = redis.from_url(
|
| 7 |
settings.redis_url,
|
| 8 |
encoding="utf-8",
|
| 9 |
decode_responses=True,
|
| 10 |
-
|
| 11 |
)
|
| 12 |
|
| 13 |
|
|
|
|
| 3 |
import redis.asyncio as redis
|
| 4 |
from src.config.settings import settings
|
| 5 |
|
| 6 |
+
# ssl_cert_reqs is only valid for SSL (rediss://) connections; passing it to a
|
| 7 |
+
# plain redis:// connection raises TypeError in the connection class.
|
| 8 |
+
_ssl_kwargs = {"ssl_cert_reqs": None} if settings.redis_url.startswith("rediss://") else {}
|
| 9 |
+
|
| 10 |
redis_client = redis.from_url(
|
| 11 |
settings.redis_url,
|
| 12 |
encoding="utf-8",
|
| 13 |
decode_responses=True,
|
| 14 |
+
**_ssl_kwargs,
|
| 15 |
)
|
| 16 |
|
| 17 |
|