laipeng/reflex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clean up redis initialization

Browse Source 
remove oxbow code now that REDIS_URL must be a real redis url
This commit is contained in:
Masen Furer 2024-12-12 01:40:14 -08:00
parent 802c7d045c
commit 8d99b7662a
No known key found for this signature in database
GPG Key ID: B0008AD22B3B3A95
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
reflex/utils/prerequisites.py
View File

@ -334,10 +334,9 @@ def get_redis() -> Redis | None:
Returns:
The asynchronous redis client.
"""
if isinstance((redis_url_or_options := parse_redis_url()), str):
return Redis.from_url(redis_url_or_options)
elif isinstance(redis_url_or_options, dict):
return Redis(**redis_url_or_options)
redis_url = parse_redis_url()
if redis_url is not None:
return Redis.from_url(redis_url)
return None
@ -347,14 +346,13 @@ def get_redis_sync() -> RedisSync | None:
Returns:
The synchronous redis client.
"""
if isinstance((redis_url_or_options := parse_redis_url()), str):
return RedisSync.from_url(redis_url_or_options)
elif isinstance(redis_url_or_options, dict):
return RedisSync(**redis_url_or_options)
redis_url = parse_redis_url()
if redis_url is not None:
return RedisSync.from_url(redis_url)
return None
def parse_redis_url() -> str | dict | None:
def parse_redis_url() -> str | None:
"""Parse the REDIS_URL in config if applicable.
Returns: