From 8d99b7662a7f1edf72150b31a7c0909ace70ea43 Mon Sep 17 00:00:00 2001 From: Masen Furer Date: Thu, 12 Dec 2024 01:40:14 -0800 Subject: [PATCH] clean up redis initialization remove oxbow code now that REDIS_URL must be a real redis url --- reflex/utils/prerequisites.py | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/reflex/utils/prerequisites.py b/reflex/utils/prerequisites.py index cc56bdf88..cd401d8b0 100644 --- a/reflex/utils/prerequisites.py +++ b/reflex/utils/prerequisites.py @@ -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: