[NOTICKET] Fix langfuse version, testing langfuse

config/constant.py

@@ -29,6 +29,12 @@ class AzureBlobConstants:
     CHUNK_SIZE: int = 4 * 1024 * 1024
     ACCOUNT_NAME: str = os.environ.get("azureai__container__account__name")
 
+@dataclass(frozen=True)
+class LangfuseConstants:
+    SECRET_KEY: str = os.environ.get("ss__langfuse__secret_key")
+    PUBLIC_KEY: str = os.environ.get("ss__langfuse__public_key")
+    HOST: str = os.environ.get("langfuse__host")
+
 @dataclass
 class ProfileFieldTypes:
     NUMERIC: List[str] = field(default_factory=lambda: ["gpa_edu_1", "gpa_edu_2", "gpa_edu_3", "yoe"])

externals/databases/database.py

@@ -13,10 +13,10 @@ DATABASE_URL = EnvPostgresConstants.CONSTRING.\
 
 engine = create_async_engine(
     DATABASE_URL,
-    echo=False,
-    future=True,
     pool_pre_ping=True,
     pool_recycle=300, 
+    pool_size=5,
+    max_overflow=10,
 )
 
 AsyncSessionLocal = async_sessionmaker(

pyproject.toml

@@ -15,7 +15,7 @@ dependencies = [
     "frontend>=0.0.3",
     "langchain>=1.2.0",
     "langchain-openai>=1.1.6",
-    "langfuse==2.33.0",
+    "langfuse>=3.0.0",
     "pandas>=2.3.3",
     "passlib==1.7.4",
     "pdf2image>=1.17.0",

requirements.txt

@@ -91,6 +91,8 @@ frozenlist==1.8.0
     # via
     #   aiohttp
     #   aiosignal
+googleapis-common-protos==1.72.0
+    # via opentelemetry-exporter-otlp-proto-http
 greenlet==3.3.1
     # via sqlalchemy
 h11==0.16.0
@@ -114,9 +116,10 @@ idna==3.11
     #   anyio
     #   email-validator
     #   httpx
-    #   langfuse
     #   requests
     #   yarl
+importlib-metadata==8.7.1
+    # via opentelemetry-api
 isodate==0.7.2
     # via azure-storage-blob
 itsdangerous==2.2.0
@@ -140,7 +143,7 @@ langchain-core==1.2.14
     #   langgraph-prebuilt
 langchain-openai==1.1.10
     # via service-explorer-backend (pyproject.toml)
-langfuse==2.33.0
+langfuse==3.14.5
     # via service-explorer-backend (pyproject.toml)
 langgraph==1.0.9
     # via langchain
@@ -173,7 +176,29 @@ multidict==6.7.1
 numpy==2.4.2
     # via pandas
 openai==2.21.0
-    # via langchain-openai
+    # via
+    #   langchain-openai
+    #   langfuse
+opentelemetry-api==1.39.1
+    # via
+    #   langfuse
+    #   opentelemetry-exporter-otlp-proto-http
+    #   opentelemetry-sdk
+    #   opentelemetry-semantic-conventions
+opentelemetry-exporter-otlp-proto-common==1.39.1
+    # via opentelemetry-exporter-otlp-proto-http
+opentelemetry-exporter-otlp-proto-http==1.39.1
+    # via langfuse
+opentelemetry-proto==1.39.1
+    # via
+    #   opentelemetry-exporter-otlp-proto-common
+    #   opentelemetry-exporter-otlp-proto-http
+opentelemetry-sdk==1.39.1
+    # via
+    #   langfuse
+    #   opentelemetry-exporter-otlp-proto-http
+opentelemetry-semantic-conventions==0.60b1
+    # via opentelemetry-sdk
 orjson==3.11.7
     # via
     #   langgraph-sdk
@@ -200,6 +225,10 @@ propcache==0.4.1
     # via
     #   aiohttp
     #   yarl
+protobuf==6.33.5
+    # via
+    #   googleapis-common-protos
+    #   opentelemetry-proto
 psycopg2==2.9.11
     # via service-explorer-backend (pyproject.toml)
 pyasn1==0.6.2
@@ -260,8 +289,10 @@ regex==2026.2.19
 requests==2.32.5
     # via
     #   azure-core
+    #   langfuse
     #   langsmith
     #   msal
+    #   opentelemetry-exporter-otlp-proto-http
     #   requests-toolbelt
     #   tiktoken
 requests-toolbelt==1.0.0
@@ -312,6 +343,10 @@ typing-extensions==4.15.0
     #   fastapi
     #   langchain-core
     #   openai
+    #   opentelemetry-api
+    #   opentelemetry-exporter-otlp-proto-http
+    #   opentelemetry-sdk
+    #   opentelemetry-semantic-conventions
     #   pydantic
     #   pydantic-core
     #   pydantic-extra-types
@@ -352,5 +387,7 @@ xxhash==3.6.0
     #   langsmith
 yarl==1.22.0
     # via aiohttp
+zipp==3.23.0
+    # via importlib-metadata
 zstandard==0.25.0
     # via langsmith

services/base/BaseGenerator.py

@@ -9,76 +9,71 @@ from tenacity import (
 )
 from typing import Dict
 
-from externals.observability.langfuse import langfuse_handler, langfuse
+# ❌ REMOVED: from externals.observability.langfuse import langfuse_handler, langfuse
 from services.llms.LLM import model_5mini, model_4omini
 from utils.decorator import trace_runtime
 from utils.logger import get_logger
 
 logger = get_logger("base generator")
 
+
 class MetadataObservability(BaseModel):
     fullname: str
     task_id: str
     agent: str
 
+
 class BaseAIGenerator:
-    """
-    Args:
-        name:str,
-        prompt: ChatPromptTemplate,
-        input_llm: Dict,
-        metadata_observability: MetadataObservability,
-        output_model: BaseModel,
-        llm:AzureChatOpenAI = model_5mini | model_4omini,
-    """
-    def __init__(self, 
-                 task_name:str,
+    def __init__(self,
+                 task_name: str,
                  prompt: ChatPromptTemplate,
                  input_llm: Dict,
                  metadata_observability: MetadataObservability,
-                 llm:AzureChatOpenAI = model_5mini | model_4omini,
+                 llm: AzureChatOpenAI = model_5mini | model_4omini,
                  ):
         self.name = task_name
-        self.llm  = llm
+        self.llm = llm
         self.prompt = prompt
         self.input_llm = input_llm
         self.metadata_observability = metadata_observability
 
+    def _get_langfuse_handler(self):
+        try:
+            import os
+            from config.constant import LangfuseConstants  # adjust import path if needed
+            os.environ["LANGFUSE_PUBLIC_KEY"] = LangfuseConstants.PUBLIC_KEY
+            os.environ["LANGFUSE_SECRET_KEY"] = LangfuseConstants.SECRET_KEY
+            os.environ["LANGFUSE_HOST"] = LangfuseConstants.HOST or "https://us.cloud.langfuse.com"
+
+            from langfuse.langchain import CallbackHandler
+            return CallbackHandler()
+        except Exception as e:
+            logger.warning(f"⚠️ Langfuse unavailable, skipping observability: {e}")
+            return None
+
     @retry(
         reraise=True,
-        stop=stop_after_attempt(2),                # retry max 3 times
-        wait=wait_exponential(multiplier=1, min=1, max=5), 
-        retry=retry_if_exception_type(Exception)   # retry on any exception from LLM
+        stop=stop_after_attempt(2),
+        wait=wait_exponential(multiplier=1, min=1, max=5),
+        retry=retry_if_exception_type(Exception)
     )
     async def _asafe_invoke(self, chain, input_llm, config):
-        """private helper for retries"""
         return await chain.ainvoke(input_llm, config=config)
-    
+
     @retry(
         reraise=True,
-        stop=stop_after_attempt(2),                # retry max 3 times
-        wait=wait_exponential(multiplier=1, min=1, max=5), 
-        retry=retry_if_exception_type(Exception)   # retry on any exception from LLM
+        stop=stop_after_attempt(2),
+        wait=wait_exponential(multiplier=1, min=1, max=5),
+        retry=retry_if_exception_type(Exception)
     )
     async def _safe_invoke(self, chain, input_llm, config):
-        """private helper for retries"""
         return chain.invoke(input_llm, config=config)
-    
+
     @trace_runtime
     async def agenerate(self):
-        trace = None
         try:
-            # ✅ Create trace (no context manager, no end())
-            trace = langfuse.trace(
-                name=self.name,
-                input=self.input_llm,
-                user_id=self.metadata_observability.fullname,
-                session_id=self.metadata_observability.task_id,
-                metadata=self.metadata_observability.model_dump(),
-            )
-
-            handler = trace.get_langchain_handler() 
-            config = {"callbacks": [handler]}
+            handler = self._get_langfuse_handler()
+            config = {"callbacks": [handler]} if handler else {}
             chain = self.prompt | self.llm
 
             output = await self._asafe_invoke(
@@ -86,37 +81,17 @@ class BaseAIGenerator:
                 input_llm=self.input_llm,
                 config=config,
             )
-
-            trace.update(output=output)
-
             return output
 
         except Exception as e:
             logger.exception("❌ BaseGenerator agenerate error")
-
-            if trace:
-                trace.update(
-                    status="error",
-                    error=str(e),
-                )
-
             return None
 
     @trace_runtime
     async def generate(self):
-        trace = None
         try:
-
-            trace = langfuse.trace(
-                name=self.name,
-                input=self.input_llm,
-                user_id=self.metadata_observability.fullname,
-                session_id=self.metadata_observability.task_id,
-                metadata=self.metadata_observability.model_dump(),
-            )
-
-            handler = trace.get_langchain_handler() 
-            config = {"callbacks": [handler]}
+            handler = self._get_langfuse_handler()
+            config = {"callbacks": [handler]} if handler else {}
             chain = self.prompt | self.llm
 
             output = self._safe_invoke(
@@ -124,20 +99,8 @@ class BaseAIGenerator:
                 input_llm=self.input_llm,
                 config=config,
             )
-
-            trace.update(output=output)
-
             return output
 
         except Exception as e:
             logger.exception("❌ BaseGenerator generate error")
-
-            if trace:
-                trace.update(
-                    status="error",
-                    error=str(e),
-                )
-
-            return None
-
-
+            return None

utils/decorator.py

@@ -44,9 +44,7 @@ def retry_db(
     delay: float = 2.0,
     backoff: float = 2.0,
 ) -> Callable:
-
     def decorator(func: Callable) -> Callable:
-
         @wraps(func)
         async def async_wrapper(*args, **kwargs) -> Any:
             current_delay = delay
@@ -58,12 +56,12 @@ def retry_db(
                 except (
                     OperationalError,
                     InterfaceError,
+                    PendingRollbackError,           # 👈 Add this
                     asyncpg.exceptions.PostgresConnectionError,
                     asyncpg.exceptions.CannotConnectNowError,
                     ConnectionError,
                     TimeoutError,
                 ) as e:
-
                     if attempt == retries:
                         raise
 
@@ -72,9 +70,16 @@ def retry_db(
                         f"after {current_delay:.2f}s due to: {type(e).__name__}"
                     )
 
+                    # 👇 Roll back the broken session before retrying
+                    db = args[0] if args else kwargs.get("db")
+                    if db is not None:
+                        try:
+                            await db.rollback()
+                        except Exception:
+                            pass  # If rollback itself fails, just continue
+
                     await asyncio.sleep(current_delay)
                     current_delay *= backoff
 
         return async_wrapper
-
     return decorator

uv.lock

@@ -678,6 +678,18 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/9a/9a/e35b4a917281c0b8419d4207f4334c8e8c5dbf4f3f5f9ada73958d937dcc/frozenlist-1.8.0-py3-none-any.whl", hash = "sha256:0c18a16eab41e82c295618a77502e17b195883241c563b00f0aa5106fc4eaa0d", size = 13409, upload-time = "2025-10-06T05:38:16.721Z" },
 ]
 
+[[package]]
+name = "googleapis-common-protos"
+version = "1.72.0"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "protobuf" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/e5/7b/adfd75544c415c487b33061fe7ae526165241c1ea133f9a9125a56b39fd8/googleapis_common_protos-1.72.0.tar.gz", hash = "sha256:e55a601c1b32b52d7a3e65f43563e2aa61bcd737998ee672ac9b951cd49319f5", size = 147433, upload-time = "2025-11-06T18:29:24.087Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/c4/ab/09169d5a4612a5f92490806649ac8d41e3ec9129c636754575b3553f4ea4/googleapis_common_protos-1.72.0-py3-none-any.whl", hash = "sha256:4299c5a82d5ae1a9702ada957347726b167f9f8d1fc352477702a1e851ff4038", size = 297515, upload-time = "2025-11-06T18:29:13.14Z" },
+]
+
 [[package]]
 name = "greenlet"
 version = "3.3.0"
@@ -777,6 +789,18 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/0e/61/66938bbb5fc52dbdf84594873d5b51fb1f7c7794e9c0f5bd885f30bc507b/idna-3.11-py3-none-any.whl", hash = "sha256:771a87f49d9defaf64091e6e6fe9c18d4833f140bd19464795bc32d966ca37ea", size = 71008, upload-time = "2025-10-12T14:55:18.883Z" },
 ]
 
+[[package]]
+name = "importlib-metadata"
+version = "8.7.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "zipp" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/f3/49/3b30cad09e7771a4982d9975a8cbf64f00d4a1ececb53297f1d9a7be1b10/importlib_metadata-8.7.1.tar.gz", hash = "sha256:49fef1ae6440c182052f407c8d34a68f72efc36db9ca90dc0113398f2fdde8bb", size = 57107, upload-time = "2025-12-21T10:00:19.278Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/fa/5e/f8e9a1d23b9c20a551a8a02ea3637b4642e22c2626e3a13a9a29cdea99eb/importlib_metadata-8.7.1-py3-none-any.whl", hash = "sha256:5a1f80bf1daa489495071efbb095d75a634cf28a8bc299581244063b53176151", size = 27865, upload-time = "2025-12-21T10:00:18.329Z" },
+]
+
 [[package]]
 name = "isodate"
 version = "0.7.2"
@@ -928,19 +952,23 @@ wheels = [
 
 [[package]]
 name = "langfuse"
-version = "2.33.0"
+version = "3.14.5"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "backoff" },
     { name = "httpx" },
-    { name = "idna" },
+    { name = "openai" },
+    { name = "opentelemetry-api" },
+    { name = "opentelemetry-exporter-otlp-proto-http" },
+    { name = "opentelemetry-sdk" },
     { name = "packaging" },
     { name = "pydantic" },
+    { name = "requests" },
     { name = "wrapt" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/04/09/98b6245b833beaf797cfc7ba97917dcc19f34209b8ff56a55a43a458420e/langfuse-2.33.0.tar.gz", hash = "sha256:3ca2ef8539a8f28cb80135f4b46b80d5585ce183f8e2035f318be296d09d7d88", size = 87438, upload-time = "2024-05-21T15:55:18.441Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/ec/6b/7a945e8bc56cbf343b6f6171fd45870b0ea80ea38463b2db8dd5a9dc04a2/langfuse-3.14.5.tar.gz", hash = "sha256:2f543ec1540053d39b08a50ed5992caf1cd54d472a55cb8e5dcf6d4fcb7ff631", size = 235474, upload-time = "2026-02-23T10:42:47.721Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/92/9e/112aa6b3a246cfe14d92323de7f3d59fb8b4cf7d8f1e1eebfa3d0e07e35f/langfuse-2.33.0-py3-none-any.whl", hash = "sha256:362e3078c5a891df0b7ba3c9ce82f046d1f0274eab3d55337e443fff526f18ad", size = 162440, upload-time = "2024-05-21T15:55:14.894Z" },
+    { url = "https://files.pythonhosted.org/packages/a3/a1/10f04224542d6a57073c4f339b6763836a0899c98966f1d4ffcf56d2cf61/langfuse-3.14.5-py3-none-any.whl", hash = "sha256:5054b1c705ec69bce2d7077ce7419727ac629159428da013790979ca9cae77d5", size = 421240, upload-time = "2026-02-23T10:42:46.085Z" },
 ]
 
 [[package]]
@@ -1267,6 +1295,88 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/27/4b/7c1a00c2c3fbd004253937f7520f692a9650767aa73894d7a34f0d65d3f4/openai-2.14.0-py3-none-any.whl", hash = "sha256:7ea40aca4ffc4c4a776e77679021b47eec1160e341f42ae086ba949c9dcc9183", size = 1067558, upload-time = "2025-12-19T03:28:43.727Z" },
 ]
 
+[[package]]
+name = "opentelemetry-api"
+version = "1.39.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "importlib-metadata" },
+    { name = "typing-extensions" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/97/b9/3161be15bb8e3ad01be8be5a968a9237c3027c5be504362ff800fca3e442/opentelemetry_api-1.39.1.tar.gz", hash = "sha256:fbde8c80e1b937a2c61f20347e91c0c18a1940cecf012d62e65a7caf08967c9c", size = 65767, upload-time = "2025-12-11T13:32:39.182Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/cf/df/d3f1ddf4bb4cb50ed9b1139cc7b1c54c34a1e7ce8fd1b9a37c0d1551a6bd/opentelemetry_api-1.39.1-py3-none-any.whl", hash = "sha256:2edd8463432a7f8443edce90972169b195e7d6a05500cd29e6d13898187c9950", size = 66356, upload-time = "2025-12-11T13:32:17.304Z" },
+]
+
+[[package]]
+name = "opentelemetry-exporter-otlp-proto-common"
+version = "1.39.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "opentelemetry-proto" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/e9/9d/22d241b66f7bbde88a3bfa6847a351d2c46b84de23e71222c6aae25c7050/opentelemetry_exporter_otlp_proto_common-1.39.1.tar.gz", hash = "sha256:763370d4737a59741c89a67b50f9e39271639ee4afc999dadfe768541c027464", size = 20409, upload-time = "2025-12-11T13:32:40.885Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/8c/02/ffc3e143d89a27ac21fd557365b98bd0653b98de8a101151d5805b5d4c33/opentelemetry_exporter_otlp_proto_common-1.39.1-py3-none-any.whl", hash = "sha256:08f8a5862d64cc3435105686d0216c1365dc5701f86844a8cd56597d0c764fde", size = 18366, upload-time = "2025-12-11T13:32:20.2Z" },
+]
+
+[[package]]
+name = "opentelemetry-exporter-otlp-proto-http"
+version = "1.39.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "googleapis-common-protos" },
+    { name = "opentelemetry-api" },
+    { name = "opentelemetry-exporter-otlp-proto-common" },
+    { name = "opentelemetry-proto" },
+    { name = "opentelemetry-sdk" },
+    { name = "requests" },
+    { name = "typing-extensions" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/80/04/2a08fa9c0214ae38880df01e8bfae12b067ec0793446578575e5080d6545/opentelemetry_exporter_otlp_proto_http-1.39.1.tar.gz", hash = "sha256:31bdab9745c709ce90a49a0624c2bd445d31a28ba34275951a6a362d16a0b9cb", size = 17288, upload-time = "2025-12-11T13:32:42.029Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/95/f1/b27d3e2e003cd9a3592c43d099d2ed8d0a947c15281bf8463a256db0b46c/opentelemetry_exporter_otlp_proto_http-1.39.1-py3-none-any.whl", hash = "sha256:d9f5207183dd752a412c4cd564ca8875ececba13be6e9c6c370ffb752fd59985", size = 19641, upload-time = "2025-12-11T13:32:22.248Z" },
+]
+
+[[package]]
+name = "opentelemetry-proto"
+version = "1.39.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "protobuf" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/49/1d/f25d76d8260c156c40c97c9ed4511ec0f9ce353f8108ca6e7561f82a06b2/opentelemetry_proto-1.39.1.tar.gz", hash = "sha256:6c8e05144fc0d3ed4d22c2289c6b126e03bcd0e6a7da0f16cedd2e1c2772e2c8", size = 46152, upload-time = "2025-12-11T13:32:48.681Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/51/95/b40c96a7b5203005a0b03d8ce8cd212ff23f1793d5ba289c87a097571b18/opentelemetry_proto-1.39.1-py3-none-any.whl", hash = "sha256:22cdc78efd3b3765d09e68bfbd010d4fc254c9818afd0b6b423387d9dee46007", size = 72535, upload-time = "2025-12-11T13:32:33.866Z" },
+]
+
+[[package]]
+name = "opentelemetry-sdk"
+version = "1.39.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "opentelemetry-api" },
+    { name = "opentelemetry-semantic-conventions" },
+    { name = "typing-extensions" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/eb/fb/c76080c9ba07e1e8235d24cdcc4d125ef7aa3edf23eb4e497c2e50889adc/opentelemetry_sdk-1.39.1.tar.gz", hash = "sha256:cf4d4563caf7bff906c9f7967e2be22d0d6b349b908be0d90fb21c8e9c995cc6", size = 171460, upload-time = "2025-12-11T13:32:49.369Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/7c/98/e91cf858f203d86f4eccdf763dcf01cf03f1dae80c3750f7e635bfa206b6/opentelemetry_sdk-1.39.1-py3-none-any.whl", hash = "sha256:4d5482c478513ecb0a5d938dcc61394e647066e0cc2676bee9f3af3f3f45f01c", size = 132565, upload-time = "2025-12-11T13:32:35.069Z" },
+]
+
+[[package]]
+name = "opentelemetry-semantic-conventions"
+version = "0.60b1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "opentelemetry-api" },
+    { name = "typing-extensions" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/91/df/553f93ed38bf22f4b999d9be9c185adb558982214f33eae539d3b5cd0858/opentelemetry_semantic_conventions-0.60b1.tar.gz", hash = "sha256:87c228b5a0669b748c76d76df6c364c369c28f1c465e50f661e39737e84bc953", size = 137935, upload-time = "2025-12-11T13:32:50.487Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/7a/5e/5958555e09635d09b75de3c4f8b9cae7335ca545d77392ffe7331534c402/opentelemetry_semantic_conventions-0.60b1-py3-none-any.whl", hash = "sha256:9fa8c8b0c110da289809292b0591220d3a7b53c1526a23021e977d68597893fb", size = 219982, upload-time = "2025-12-11T13:32:36.955Z" },
+]
+
 [[package]]
 name = "orjson"
 version = "3.11.5"
@@ -1531,6 +1641,21 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/5b/5a/bc7b4a4ef808fa59a816c17b20c4bef6884daebbdf627ff2a161da67da19/propcache-0.4.1-py3-none-any.whl", hash = "sha256:af2a6052aeb6cf17d3e46ee169099044fd8224cbaf75c76a2ef596e8163e2237", size = 13305, upload-time = "2025-10-08T19:49:00.792Z" },
 ]
 
+[[package]]
+name = "protobuf"
+version = "6.33.5"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/ba/25/7c72c307aafc96fa87062aa6291d9f7c94836e43214d43722e86037aac02/protobuf-6.33.5.tar.gz", hash = "sha256:6ddcac2a081f8b7b9642c09406bc6a4290128fce5f471cddd165960bb9119e5c", size = 444465, upload-time = "2026-01-29T21:51:33.494Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/b1/79/af92d0a8369732b027e6d6084251dd8e782c685c72da161bd4a2e00fbabb/protobuf-6.33.5-cp310-abi3-win32.whl", hash = "sha256:d71b040839446bac0f4d162e758bea99c8251161dae9d0983a3b88dee345153b", size = 425769, upload-time = "2026-01-29T21:51:21.751Z" },
+    { url = "https://files.pythonhosted.org/packages/55/75/bb9bc917d10e9ee13dee8607eb9ab963b7cf8be607c46e7862c748aa2af7/protobuf-6.33.5-cp310-abi3-win_amd64.whl", hash = "sha256:3093804752167bcab3998bec9f1048baae6e29505adaf1afd14a37bddede533c", size = 437118, upload-time = "2026-01-29T21:51:24.022Z" },
+    { url = "https://files.pythonhosted.org/packages/a2/6b/e48dfc1191bc5b52950246275bf4089773e91cb5ba3592621723cdddca62/protobuf-6.33.5-cp39-abi3-macosx_10_9_universal2.whl", hash = "sha256:a5cb85982d95d906df1e2210e58f8e4f1e3cdc088e52c921a041f9c9a0386de5", size = 427766, upload-time = "2026-01-29T21:51:25.413Z" },
+    { url = "https://files.pythonhosted.org/packages/4e/b1/c79468184310de09d75095ed1314b839eb2f72df71097db9d1404a1b2717/protobuf-6.33.5-cp39-abi3-manylinux2014_aarch64.whl", hash = "sha256:9b71e0281f36f179d00cbcb119cb19dec4d14a81393e5ea220f64b286173e190", size = 324638, upload-time = "2026-01-29T21:51:26.423Z" },
+    { url = "https://files.pythonhosted.org/packages/c5/f5/65d838092fd01c44d16037953fd4c2cc851e783de9b8f02b27ec4ffd906f/protobuf-6.33.5-cp39-abi3-manylinux2014_s390x.whl", hash = "sha256:8afa18e1d6d20af15b417e728e9f60f3aa108ee76f23c3b2c07a2c3b546d3afd", size = 339411, upload-time = "2026-01-29T21:51:27.446Z" },
+    { url = "https://files.pythonhosted.org/packages/9b/53/a9443aa3ca9ba8724fdfa02dd1887c1bcd8e89556b715cfbacca6b63dbec/protobuf-6.33.5-cp39-abi3-manylinux2014_x86_64.whl", hash = "sha256:cbf16ba3350fb7b889fca858fb215967792dc125b35c7976ca4818bee3521cf0", size = 323465, upload-time = "2026-01-29T21:51:28.925Z" },
+    { url = "https://files.pythonhosted.org/packages/57/bf/2086963c69bdac3d7cff1cc7ff79b8ce5ea0bec6797a017e1be338a46248/protobuf-6.33.5-py3-none-any.whl", hash = "sha256:69915a973dd0f60f31a08b8318b73eab2bd6a392c79184b3612226b0a3f8ec02", size = 170687, upload-time = "2026-01-29T21:51:32.557Z" },
+]
+
 [[package]]
 name = "psycopg2"
 version = "2.9.11"
@@ -2060,7 +2185,7 @@ requires-dist = [
     { name = "frontend", specifier = ">=0.0.3" },
     { name = "langchain", specifier = ">=1.2.0" },
     { name = "langchain-openai", specifier = ">=1.1.6" },
-    { name = "langfuse", specifier = "==2.33.0" },
+    { name = "langfuse", specifier = ">=3.0.0" },
     { name = "pandas", specifier = ">=2.3.3" },
     { name = "passlib", specifier = "==1.7.4" },
     { name = "pdf2image", specifier = ">=1.17.0" },
@@ -2592,6 +2717,15 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/73/ae/b48f95715333080afb75a4504487cbe142cae1268afc482d06692d605ae6/yarl-1.22.0-py3-none-any.whl", hash = "sha256:1380560bdba02b6b6c90de54133c81c9f2a453dee9912fe58c1dcced1edb7cff", size = 46814, upload-time = "2025-10-06T14:12:53.872Z" },
 ]
 
+[[package]]
+name = "zipp"
+version = "3.23.0"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/e3/02/0f2892c661036d50ede074e376733dca2ae7c6eb617489437771209d4180/zipp-3.23.0.tar.gz", hash = "sha256:a07157588a12518c9d4034df3fbbee09c814741a33ff63c05fa29d26a2404166", size = 25547, upload-time = "2025-06-08T17:06:39.4Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/2e/54/647ade08bf0db230bfea292f893923872fd20be6ac6f53b2b936ba839d75/zipp-3.23.0-py3-none-any.whl", hash = "sha256:071652d6115ed432f5ce1d34c336c0adfd6a884660d1e9712a256d3d3bd4b14e", size = 10276, upload-time = "2025-06-08T17:06:38.034Z" },
+]
+
 [[package]]
 name = "zstandard"
 version = "0.25.0"