Flush Redis DB on startup.

This commit is contained in:
SergeantPanda 2025-04-04 16:31:36 -05:00
parent 755d6c7865
commit f71e1aadd4

View file

@ -29,6 +29,7 @@ def wait_for_redis(host='localhost', port=6379, db=0, max_retries=30, retry_inte
socket_connect_timeout=2 socket_connect_timeout=2
) )
redis_client.ping() redis_client.ping()
redis_client.flushdb() # Flush the database to ensure it's clean
logger.info(f"✅ Redis at {host}:{port}/{db} is now available!") logger.info(f"✅ Redis at {host}:{port}/{db} is now available!")
return True return True
except (redis.exceptions.ConnectionError, redis.exceptions.TimeoutError) as e: except (redis.exceptions.ConnectionError, redis.exceptions.TimeoutError) as e: