diff --git a/core/utils.py b/core/utils.py
index 2020c264..e89e5f33 100644
--- a/core/utils.py
+++ b/core/utils.py
@@ -50,6 +50,7 @@ def get_redis_client(max_retries=5, retry_interval=1):
 
             # Validate connection with ping
             client.ping()
+            client.flushdb()
             logger.info(f"Connected to Redis at {redis_host}:{redis_port}/{redis_db}")
             return client