mirror of https://github.com/kortix-ai/suna.git
fix: update Redis SSL environment variable handling
This commit is contained in:
parent
0d420eedc3
commit
5a3bf357a8
|
@ -25,7 +25,9 @@ def initialize():
|
||||||
redis_host = os.getenv('REDIS_HOST', 'redis')
|
redis_host = os.getenv('REDIS_HOST', 'redis')
|
||||||
redis_port = int(os.getenv('REDIS_PORT', 6379))
|
redis_port = int(os.getenv('REDIS_PORT', 6379))
|
||||||
redis_password = os.getenv('REDIS_PASSWORD', '')
|
redis_password = os.getenv('REDIS_PASSWORD', '')
|
||||||
redis_ssl = os.getenv('REDIS_SSL', False)
|
# Convert string 'True'/'False' to boolean
|
||||||
|
redis_ssl_str = os.getenv('REDIS_SSL', 'False')
|
||||||
|
redis_ssl = redis_ssl_str.lower() == 'true'
|
||||||
|
|
||||||
logger.info(f"Initializing Redis connection to {redis_host}:{redis_port}")
|
logger.info(f"Initializing Redis connection to {redis_host}:{redis_port}")
|
||||||
|
|
||||||
|
@ -146,4 +148,4 @@ async def expire(key: str, time: int):
|
||||||
async def keys(pattern: str) -> List[str]:
|
async def keys(pattern: str) -> List[str]:
|
||||||
"""Get keys matching a pattern."""
|
"""Get keys matching a pattern."""
|
||||||
redis_client = await get_client()
|
redis_client = await get_client()
|
||||||
return await redis_client.keys(pattern)
|
return await redis_client.keys(pattern)
|
Loading…
Reference in New Issue