do not remove endpoint prefix before /v1/traces

Author: soapun

packages/phoenix-otel/src/phoenix/otel/otel.py

@@ -729,7 +729,10 @@ def _construct_http_endpoint(parsed_endpoint: ParseResult) -> ParseResult:
     Returns:
         ParseResult: Modified endpoint with "/v1/traces" path.
     """
-    return parsed_endpoint._replace(path="/v1/traces")
+    traces_suffix = "/v1/traces"
+    if parsed_endpoint.path.endswith(traces_suffix):
+        return parsed_endpoint
+    return parsed_endpoint._replace(path=traces_suffix)
 
 
 def _construct_phoenix_cloud_endpoint(parsed_endpoint: ParseResult) -> ParseResult:

packages/phoenix-otel/tests/test_settings.py

@@ -1,9 +1,11 @@
 import os
 from typing import Optional
 from unittest.mock import patch
+from urllib.parse import urlparse
 
 import pytest
 
+from phoenix.otel.otel import _construct_http_endpoint
 from phoenix.otel.settings import get_env_collector_endpoint
 
 
@@ -25,3 +27,17 @@
 def test_get_env_collector_endpoint(env: dict[str, str], expected: Optional[str]) -> None:
     with patch.dict(os.environ, env, clear=True):
         assert get_env_collector_endpoint() == expected
+
+
+@pytest.mark.parametrize(
+    "endpoint, expected",
+    [
+        ("http://localhost:6006", "http://localhost:6006/v1/traces"),
+        ("http://localhost:6006/v1/traces", "http://localhost:6006/v1/traces"),
+        ("http://localhost:6006/prefix/v1/traces", "http://localhost:6006/prefix/v1/traces"),
+    ],
+)
+def test_construct_http_endpoint(endpoint: str, expected: str) -> None:
+    parsed = urlparse(endpoint)
+    result = _construct_http_endpoint(parsed)
+    assert result.geturl() == expected