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: