From ace34b9a91e8d4c9c4e4ba724fab71fd88756319 Mon Sep 17 00:00:00 2001
From: hajdul88 <52442977+hajdul88@users.noreply.github.com>
Date: Thu, 15 Jan 2026 11:56:01 +0100
Subject: [PATCH] feat: adds log key to RedisAdapter

---
 .../infrastructure/databases/cache/redis/RedisAdapter.py   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/cognee/infrastructure/databases/cache/redis/RedisAdapter.py b/cognee/infrastructure/databases/cache/redis/RedisAdapter.py
index d3809f4dc..98021e968 100644
--- a/cognee/infrastructure/databases/cache/redis/RedisAdapter.py
+++ b/cognee/infrastructure/databases/cache/redis/RedisAdapter.py
@@ -17,13 +17,14 @@ class RedisAdapter(CacheDBInterface):
         host,
         port,
         lock_name="default_lock",
+        log_key="usage_logs",
         username=None,
         password=None,
         timeout=240,
         blocking_timeout=300,
         connection_timeout=30,
     ):
-        super().__init__(host, port, lock_name)
+        super().__init__(host, port, lock_name, log_key)
 
         self.host = host
         self.port = port
@@ -195,7 +196,7 @@ class RedisAdapter(CacheDBInterface):
             CacheConnectionError: If Redis connection fails or times out.
         """
         try:
-            usage_logs_key = f"usage_logs:{user_id}"
+            usage_logs_key = f"{self.log_key}:{user_id}"
 
             await self.async_redis.rpush(usage_logs_key, json.dumps(log_entry))
 
@@ -223,7 +224,7 @@ class RedisAdapter(CacheDBInterface):
             List of usage log entries, most recent first.
         """
         try:
-            usage_logs_key = f"usage_logs:{user_id}"
+            usage_logs_key = f"{self.log_key}:{user_id}"
             entries = await self.async_redis.lrange(usage_logs_key, -limit, -1)
             return [json.loads(e) for e in reversed(entries)] if entries else []
         except (redis.ConnectionError, redis.TimeoutError) as e: