fix: tracing headers

Author: mrkaye97

hatchet_sdk/utils/tracing.py

@@ -16,6 +16,18 @@
 OTEL_CARRIER_KEY = "__otel_carrier"
 
 
+def parse_headers(headers: str | None) -> dict[str, str]:
+    if headers is None:
+        return {}
+
+    try:
+        otel_header_key, api_key = headers.split("=", maxsplit=1)
+
+        return {otel_header_key: api_key}
+    except ValueError:
+        raise ValueError("OTLP headers must be in the format `key=value`")
+
+
 @cache
 def create_tracer(config: ClientConfig) -> Tracer:
     ## TODO: Figure out how to specify protocol here
@@ -27,7 +39,7 @@ def create_tracer(config: ClientConfig) -> Tracer:
         processor = BatchSpanProcessor(
             OTLPSpanExporter(
                 endpoint=config.otel_exporter_oltp_endpoint,
-                headers=config.otel_exporter_oltp_headers,
+                headers=parse_headers(config.otel_exporter_oltp_headers),
             ),
         )
 
@@ -67,4 +79,4 @@ def parse_carrier_from_metadata(metadata: dict[str, Any] | None) -> Context | No
         TraceContextTextMapPropagator().extract(_ctx)
         if (_ctx := metadata.get(OTEL_CARRIER_KEY))
         else None
-    )
+    )