feat: implement FastAPI application with Pinecone/Redis integration and candidate matching router

backend/main.py

@@ -1,5 +1,7 @@
 import os
 import logging
+import json
+import redis.asyncio as redis
 from contextlib import asynccontextmanager
 from fastapi import FastAPI, Request
 from fastapi.middleware.cors import CORSMiddleware
@@ -15,16 +17,22 @@ settings = get_settings()
 
 _pc_client: Pinecone | None = None
 _pc_ready: bool = False
+_redis_client: redis.Redis | None = None
 
 
 def get_pinecone() -> Pinecone:
     return _pc_client
 
 
+def get_redis() -> redis.Redis:
+    return _redis_client
+
+
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    global _pc_client, _pc_ready
+    global _pc_client, _pc_ready, _redis_client
     _pc_client = Pinecone(api_key=settings.pinecone_api_key)
+    _redis_client = redis.from_url(settings.redis_url, decode_responses=False)
 
     try:
         existing = [idx.name for idx in _pc_client.list_indexes()]
@@ -40,14 +48,15 @@ async def lifespan(app: FastAPI):
     except Exception as exc:
         _pc_ready = False
         logger.warning(
-            "Pinecone unavailable at startup (%s). "
-            "The API will start but vector search will fail until Pinecone is reachable.",
+            "Pinecone unavailable at startup (%s).",
             exc,
         )
 
     app.state.pinecone = _pc_client
     app.state.pinecone_ready = _pc_ready
+    app.state.redis = _redis_client
     yield
+    await _redis_client.close()
 
 
 app = FastAPI(
@@ -74,10 +83,12 @@ app.include_router(matching.router, prefix="/api/match", tags=["Matching"])
 @app.get("/health")
 async def health(request: "Request"):
     pc_ok = getattr(request.app.state, "pinecone_ready", False)
+    redis_conn = getattr(request.app.state, "redis", None)
     return {
         "status": "ok",
         "version": "1.0.0",
         "pinecone": "connected" if pc_ok else "unavailable",
+        "redis": "ok" if redis_conn else "missing",
     }
 
 

backend/src/routers/matching.py

@@ -128,11 +128,11 @@ async def trigger_match(
 @router.get("/{jd_id}", response_model=MatchResponse)
 async def get_match_results(
     jd_id: uuid.UUID,
+    request: Request,
     session_id: uuid.UUID | None = Query(None),
     db: AsyncSession = Depends(get_db),
 ):
-    settings = get_settings()
-    r = redis.Redis.from_url(settings.redis_url)
+    r = request.app.state.redis
     cache_key = f"match_v2:{jd_id}:{session_id or 'none'}"
 
     try:

backend/src/workers/celery_app.py

@@ -21,4 +21,6 @@ celery_app.conf.update(
     result_expires=3600,
     worker_prefetch_multiplier=1,
     task_acks_late=True,
+    broker_pool_limit=1,
+    redis_max_connections=5,
 )