olololo

app/core/observability.py

@@ -10,7 +10,6 @@ from typing import Optional, Dict, Any
 from functools import wraps
 from contextlib import contextmanager
 import asyncio
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import _parse_otlp_headers
 from opentelemetry import trace, metrics, logs
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import BatchSpanProcessor
@@ -28,6 +27,24 @@ from starlette.requests import Request
 
 logger = logging.getLogger(__name__)
 
+# ============================================================
+# Helper Functions
+# ============================================================
+
+def _parse_otlp_headers(headers_str: str) -> Dict[str, str]:
+    """Parse OTEL_EXPORTER_OTLP_HEADERS (format: key1=val1,key2=val2)"""
+    headers = {}
+    try:
+        if not headers_str:
+            return headers
+        for pair in headers_str.split(","):
+            if "=" in pair:
+                key, val = pair.split("=", 1)
+                headers[key.strip()] = val.strip()
+    except Exception as e:
+        logger.warning(f"Failed to parse OTLP headers: {e}")
+    return headers
+
 # ============================================================
 # Configuration
 # ============================================================
@@ -44,7 +61,7 @@ class ObservabilityConfig:
     OTLP_ENDPOINT: Optional[str] = os.getenv("OTEL_EXPORTER_OTLP_ENDPOINT")
     OTLP_HEADERS: Dict[str, str] = _parse_otlp_headers(
         os.getenv("OTEL_EXPORTER_OTLP_HEADERS", "")
-    ) if os.getenv("OTEL_EXPORTER_OTLP_HEADERS") else {}
+    )
     
     # Sampling
     TRACE_SAMPLE_RATE: float = float(os.getenv("OTEL_TRACE_SAMPLE_RATE", "0.1"))
@@ -52,18 +69,6 @@ class ObservabilityConfig:
     # Console export for development
     CONSOLE_EXPORT: bool = os.getenv("OTEL_CONSOLE_EXPORT", "false").lower() == "true"
 
-def _parse_otlp_headers(headers_str: str) -> Dict[str, str]:
-    """Parse OTEL_EXPORTER_OTLP_HEADERS (format: key1=val1,key2=val2)"""
-    headers = {}
-    try:
-        for pair in headers_str.split(","):
-            if "=" in pair:
-                key, val = pair.split("=", 1)
-                headers[key.strip()] = val.strip()
-    except Exception as e:
-        logger.warning(f"Failed to parse OTLP headers: {e}")
-    return headers
-
 # ============================================================
 # Initialize Tracing
 # ============================================================
@@ -71,7 +76,7 @@ def _parse_otlp_headers(headers_str: str) -> Dict[str, str]:
 def init_tracing():
     """Initialize OpenTelemetry tracing"""
     if not ObservabilityConfig.ENABLED:
-        logger.info("⚠️ OpenTelemetry disabled (OTEL_ENABLED=false)")
+        logger.info("âš ï¸ OpenTelemetry disabled (OTEL_ENABLED=false)")
         return
     
     try:
@@ -93,22 +98,22 @@ def init_tracing():
                     headers=ObservabilityConfig.OTLP_HEADERS,
                 )
                 tracer_provider.add_span_processor(BatchSpanProcessor(exporter))
-                logger.info(f"✅ OTLP exporter configured: {ObservabilityConfig.OTLP_ENDPOINT}")
+                logger.info(f"✅ OTLP exporter configured: {ObservabilityConfig.OTLP_ENDPOINT}")
             except Exception as e:
-                logger.warning(f"⚠️ OTLP exporter failed: {e}")
+                logger.warning(f"âš ï¸ OTLP exporter failed: {e}")
         
         # Console export for development
         if ObservabilityConfig.CONSOLE_EXPORT or ObservabilityConfig.ENVIRONMENT == "development":
             from opentelemetry.sdk.trace.export import SimpleSpanProcessor, ConsoleSpanExporter
             tracer_provider.add_span_processor(SimpleSpanProcessor(ConsoleSpanExporter()))
-            logger.info("✅ Console span exporter enabled")
+            logger.info("✅ Console span exporter enabled")
         
         # Set global tracer provider
         trace.set_tracer_provider(tracer_provider)
-        logger.info("✅ OpenTelemetry tracing initialized")
+        logger.info("✅ OpenTelemetry tracing initialized")
         
     except Exception as e:
-        logger.error(f"❌ Failed to initialize tracing: {e}")
+        logger.error(f"⌠Failed to initialize tracing: {e}")
         raise
 
 # ============================================================
@@ -138,19 +143,19 @@ def init_metrics():
                 metric_readers.append(
                     PeriodicExportingMetricReader(exporter, interval_millis=5000)
                 )
-                logger.info("✅ OTLP metrics exporter configured")
+                logger.info("✅ OTLP metrics exporter configured")
             except Exception as e:
-                logger.warning(f"⚠️ OTLP metrics exporter failed: {e}")
+                logger.warning(f"âš ï¸ OTLP metrics exporter failed: {e}")
         
         meter_provider = MeterProvider(
             resource=resource,
             metric_readers=metric_readers,
         )
         metrics.set_meter_provider(meter_provider)
-        logger.info("✅ OpenTelemetry metrics initialized")
+        logger.info("✅ OpenTelemetry metrics initialized")
         
     except Exception as e:
-        logger.error(f"❌ Failed to initialize metrics: {e}")
+        logger.error(f"⌠Failed to initialize metrics: {e}")
 
 # ============================================================
 # Instrumentation
@@ -166,9 +171,9 @@ def instrument_fastapi(app):
             app,
             excluded_urls="docs,openapi.json,health",
         )
-        logger.info("✅ FastAPI instrumented")
+        logger.info("✅ FastAPI instrumented")
     except Exception as e:
-        logger.warning(f"⚠️ FastAPI instrumentation failed: {e}")
+        logger.warning(f"âš ï¸ FastAPI instrumentation failed: {e}")
 
 def instrument_libraries():
     """Auto-instrument external libraries"""
@@ -179,9 +184,9 @@ def instrument_libraries():
         HTTPXClientInstrumentor().instrument()
         RequestsInstrumentor().instrument()
         RedisInstrumentor().instrument()
-        logger.info("✅ External libraries instrumented")
+        logger.info("✅ External libraries instrumented")
     except Exception as e:
-        logger.warning(f"⚠️ Library instrumentation failed: {e}")
+        logger.warning(f"âš ï¸ Library instrumentation failed: {e}")
 
 # ============================================================
 # Custom Tracer & Metrics

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/53aa51172d142c89d9012cce15ae4d6cc0ca6895895114379cacb4fab128d9db

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:53aa51172d142c89d9012cce15ae4d6cc0ca6895895114379cacb4fab128d9db
+size 90868376

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/58d4a9a45664eb9e12de9549c548c09b6134c17f

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:7dfc82496ec33f906b5b0d6750c1e2397da6530c74d1ae3568c55bc2739125e7
+size 10454

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/59d594003bf59880a884c574bf88ef7555bb0202

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:fc1993fde0a95c24ec6c022539d41cf6e2f7c9721e5415d6fb6897472a9cd4b7
+size 53

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/72b987fd805cfa2b58c4c8c952b274a11bfd5a00

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:953f9c0d463486b10a6871cc2fd59f223b2c70184f49815e7efbcab5d8908b41
+size 612

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/952a9b81c0bfd99800fabf352f69c7ccd46c5e43

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:84e40c8e006c9b1d6c122e02cba9b02458120b5fb0c87b746c41e0207cf642cf
+size 349

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/c79f2b6a0cea6f4b564fed1938984bace9d30ff0

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:acb92769e8195aabd29b7b2137a9e6d6e25c476a4f15aa4355c233426c61576b
+size 350

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/cb202bfe2e3c98645018a6d12f182a434c9d3e02

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:be50c3628f2bf5bb5e3a7f17b1f74611b2561a3a27eeab05e5aa30f411572037
+size 466247

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/d1514c3162bbe87b343f565fadc62e6c06f04f03

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:4be450dde3b0273bb9787637cfbd28fe04a7ba6ab9d36ac48e92b11e350ffc23
+size 190

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/e7b0375001f109a6b8873d756ad4f7bbb15fbaa5

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:303df45a03609e4ead04bc3dc1536d0ab19b5358db685b6f3da123d05ec200e3
+size 112

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/fb140275c155a9c7c5a3b3e0e77a9e839594a938

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:07eced375cec144d27c900241f3e339478dec958f92fddbc551f295c992038a3
+size 231508

models/models--sentence-transformers--all-MiniLM-L6-v2/blobs/fd1b291129c607e5d49799f87cb219b27f98acdf

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:061ca9d39661d6c6d6de5ba27f79a1cd5770ea247f8d46412a68a498dc5ac9f3
+size 116

models/models--sentence-transformers--all-MiniLM-L6-v2/refs/main

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:edb692c300dcf5dd2a56116221d7613e9d360b6f0be22bc3e02e040e095b135b
+size 40

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/1_Pooling/config.json

@@ -0,0 +1 @@
+../../../blobs/d1514c3162bbe87b343f565fadc62e6c06f04f03

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/README.md

@@ -0,0 +1 @@
+../../blobs/58d4a9a45664eb9e12de9549c548c09b6134c17f

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/config.json

@@ -0,0 +1 @@
+../../blobs/72b987fd805cfa2b58c4c8c952b274a11bfd5a00

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/config_sentence_transformers.json

@@ -0,0 +1 @@
+../../blobs/fd1b291129c607e5d49799f87cb219b27f98acdf

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/model.safetensors

@@ -0,0 +1 @@
+../../blobs/53aa51172d142c89d9012cce15ae4d6cc0ca6895895114379cacb4fab128d9db

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/modules.json

@@ -0,0 +1 @@
+../../blobs/952a9b81c0bfd99800fabf352f69c7ccd46c5e43

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/sentence_bert_config.json

@@ -0,0 +1 @@
+../../blobs/59d594003bf59880a884c574bf88ef7555bb0202

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/special_tokens_map.json

@@ -0,0 +1 @@
+../../blobs/e7b0375001f109a6b8873d756ad4f7bbb15fbaa5

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/tokenizer.json

@@ -0,0 +1 @@
+../../blobs/cb202bfe2e3c98645018a6d12f182a434c9d3e02

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/tokenizer_config.json

@@ -0,0 +1 @@
+../../blobs/c79f2b6a0cea6f4b564fed1938984bace9d30ff0

models/models--sentence-transformers--all-MiniLM-L6-v2/snapshots/c9745ed1d9f207416be6d2e6f8de32d1f16199bf/vocab.txt

@@ -0,0 +1 @@
+../../blobs/fb140275c155a9c7c5a3b3e0e77a9e839594a938

models/sentence-transformers_all-MiniLM-L6-v2/.gitattributes

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:98ccb431c012ebfe976280fbd45aea4cec7409935868ccecf3954370f96732a1
+size 1229

models/sentence-transformers_all-MiniLM-L6-v2/1_Pooling/config.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:4be450dde3b0273bb9787637cfbd28fe04a7ba6ab9d36ac48e92b11e350ffc23
+size 190

models/sentence-transformers_all-MiniLM-L6-v2/README.md

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:7dfc82496ec33f906b5b0d6750c1e2397da6530c74d1ae3568c55bc2739125e7
+size 10454

models/sentence-transformers_all-MiniLM-L6-v2/config.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:953f9c0d463486b10a6871cc2fd59f223b2c70184f49815e7efbcab5d8908b41
+size 612

models/sentence-transformers_all-MiniLM-L6-v2/config_sentence_transformers.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:061ca9d39661d6c6d6de5ba27f79a1cd5770ea247f8d46412a68a498dc5ac9f3
+size 116

models/sentence-transformers_all-MiniLM-L6-v2/data_config.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:32edcb108fc2516b920734a862ae0692bcae1c5d45d5f8d972cb0d53434a4c54
+size 39265

models/sentence-transformers_all-MiniLM-L6-v2/model.safetensors

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:53aa51172d142c89d9012cce15ae4d6cc0ca6895895114379cacb4fab128d9db
+size 90868376

models/sentence-transformers_all-MiniLM-L6-v2/modules.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:84e40c8e006c9b1d6c122e02cba9b02458120b5fb0c87b746c41e0207cf642cf
+size 349

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:6fd5d72fe4589f189f8ebc006442dbb529bb7ce38f8082112682524616046452
+size 90405214

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_O1.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:1391c6fc20b5530250bc15cbe1f47578ffeca55ab0551d335cc668b6299a88ec
+size 90360328

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_O2.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:1de3905029190b398c7d300b530e320cf4b5e7d3dfb9af1429ebd73fd9a16faf
+size 90326566

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_O3.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:a44f671e364dddbac31f203f07b91be6b0a35e51936e5ebfab65b6d9538b83ff
+size 90326497

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_O4.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:1667d7f3ba669048b13a96ee3a44456d5e42c8f44588ae8b603430e16160c485
+size 45212349

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_qint8_arm64.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:4278337fd0ff3c68bfb6291042cad8ab363e1d9fbc43dcb499fe91c871902474
+size 23026053

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_qint8_avx512.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:4278337fd0ff3c68bfb6291042cad8ab363e1d9fbc43dcb499fe91c871902474
+size 23026053

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_qint8_avx512_vnni.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:4278337fd0ff3c68bfb6291042cad8ab363e1d9fbc43dcb499fe91c871902474
+size 23026053

models/sentence-transformers_all-MiniLM-L6-v2/onnx/model_quint8_avx2.onnx

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:b941bf19f1f1283680f449fa6a7336bb5600bdcd5f84d10ddc5cd72218a0fd21
+size 23046789

models/sentence-transformers_all-MiniLM-L6-v2/openvino/openvino_model.bin

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:8b86cab4722e2aefab310cf96d4d5a9eb3b187f7d9670a082afc55c7fa0d392a
+size 90265744

models/sentence-transformers_all-MiniLM-L6-v2/openvino/openvino_model.xml

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:f87dd1482b2a745f8c699b81ddd9cbcad666a193be4693abcea44b7ac8c67c1e
+size 211315

models/sentence-transformers_all-MiniLM-L6-v2/openvino/openvino_model_qint8_quantized.bin

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:c92ea4af3c6bc7b4a0f3b3d61b147c850f4dbdd7c9e7beee0c0c70dc12da289b
+size 22933664

models/sentence-transformers_all-MiniLM-L6-v2/openvino/openvino_model_qint8_quantized.xml

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:a19425e3f56f7736f752923f0a0b5a8d61c7878017f02e1fc9086615391105dd
+size 368006

models/sentence-transformers_all-MiniLM-L6-v2/pytorch_model.bin

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:c3a85f238711653950f6a79ece63eb0ea93d76f6a6284be04019c53733baf256
+size 90888945

models/sentence-transformers_all-MiniLM-L6-v2/sentence_bert_config.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:fc1993fde0a95c24ec6c022539d41cf6e2f7c9721e5415d6fb6897472a9cd4b7
+size 53

models/sentence-transformers_all-MiniLM-L6-v2/special_tokens_map.json

@@ -0,0 +1,3 @@
+version https://git-lfs.github.com/spec/v1
+oid sha256:303df45a03609e4ead04bc3dc1536d0ab19b5358db685b6f3da123d05ec200e3
+size 112