aded safe redis decode

app/main.py

@@ -35,6 +35,11 @@ logging.basicConfig(
 )
 logger = logging.getLogger(__name__)
 
+def safe_redis_decode(value):
+    """Safely decode Redis values that might be bytes or str"""
+    if isinstance(value, bytes):
+        return value.decode('utf-8')
+    return value
 # ─── Lifespan Management ───────────────────────────────────────────────────────
 @asynccontextmanager
 async def lifespan(app: FastAPI):
@@ -91,7 +96,7 @@ async def lifespan(app: FastAPI):
     try:
         active_orgs = redis.keys("entity:*")
         for key in active_orgs:
-            key_parts = key.decode().split(":")
+            key_parts = safe_redis_decode(key).split(":")
             if len(key_parts) >= 3:
                 org_id, source_id = key_parts[1], key_parts[2]
                 stream_key = f"stream:analytics:{org_id}:{source_id}"
@@ -274,7 +279,7 @@ async def continuous_kpi_refresh():
             
             active_keys = redis.keys("entity:*")
             for key in active_keys:
-                key_parts = key.decode().split(":")
+                key_parts = safe_redis_decode(key).split(":")
                 if len(key_parts) >= 3:
                     org_id, source_id = key_parts[1], key_parts[2]