10th

.env

@@ -17,7 +17,7 @@ QDRANT_API_KEY="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJhY2Nlc3MiOiJtIn0.NRbT0QP
 
 
 # ---------- REDIS ----------
-REDIS_HOST="https://steady-clam-77697.upstash.io"
+REDIS_HOST="steady-clam-77697.upstash.io"
 REDIS_PORT=6379
 REDIS_PASSWORD="gQAAAAAAAS-BAAIncDFiM2E3OGQ1MmU5Zjk0OGM5ODU2ZmMzYzc4NjZjYzdjMHAxNzc2OTc"
 

celery_app.py

@@ -1,24 +1,37 @@
 # celery_app.py
 from celery import Celery
 import redis
+from urllib.parse import urlparse
 from config import get_settings
 
 settings = get_settings()
 
-# Upstash sometimes shows the endpoint as "host:port" in their console.
-# Split here so users can paste either format into the REDIS_HOST secret.
-_raw_host = settings.REDIS_HOST
-if ":" in _raw_host:
-    REDIS_HOST, _port_str = _raw_host.rsplit(":", 1)
-    REDIS_PORT = int(_port_str)
-else:
-    REDIS_HOST = _raw_host
-    REDIS_PORT = settings.REDIS_PORT
+def parse_redis_host(raw: str, default_port: int) -> tuple[str, int]:
+    """
+    Accept any of these formats for REDIS_HOST:
+      - "my-host.upstash.io"
+      - "my-host.upstash.io:6379"
+      - "https://my-host.upstash.io"
+      - "rediss://my-host.upstash.io:6379"
+    Always returns (hostname, port).
+    """
+    raw = raw.strip()
+    # If there's a scheme, use urlparse
+    if "://" in raw:
+        parsed = urlparse(raw)
+        host = parsed.hostname or raw
+        port = parsed.port or default_port
+    elif ":" in raw:
+        host, port_str = raw.rsplit(":", 1)
+        port = int(port_str)
+    else:
+        host = raw
+        port = default_port
+    return host, port
 
+REDIS_HOST, REDIS_PORT = parse_redis_host(settings.REDIS_HOST, settings.REDIS_PORT)
 REDIS_PASSWORD = settings.REDIS_PASSWORD
 
-# Upstash (and most managed Redis) uses rediss:// (TLS)
-# Local/Docker Redis uses redis:// (plain)
 if REDIS_PASSWORD:
     BROKER_URL  = f"rediss://:{REDIS_PASSWORD}@{REDIS_HOST}:{REDIS_PORT}/0?ssl_cert_reqs=CERT_NONE"
     BACKEND_URL = f"rediss://:{REDIS_PASSWORD}@{REDIS_HOST}:{REDIS_PORT}/1?ssl_cert_reqs=CERT_NONE"