Debugging encoding

.github/workflows/docker-build-experimental.yml

@@ -4,6 +4,7 @@ on:
   push:
     branches:
       - sessions
+      - managed-phoenix/test
 
 jobs:
   push_to_registry:

src/phoenix/server/api/routers/v1/spans.py

@@ -93,6 +93,10 @@ async def query_spans_handler(
             detail=f"Invalid query: {e}",
             status_code=HTTP_422_UNPROCESSABLE_ENTITY,
         )
+    print(f"{queries=}\n\n")
+    print(f"{span_queries=}\n\n")
+    print(f"{project_name=}\n\n")
+    print(f"{end_time=}\n\n")
     async with request.app.state.db() as session:
         results = []
         for query in span_queries:
@@ -114,14 +118,15 @@ async def query_spans_handler(
             )
     if not results:
         raise HTTPException(status_code=HTTP_404_NOT_FOUND)
+    print(f"{results=}\n\n")
 
     async def content() -> AsyncIterator[bytes]:
         for result in results:
             yield df_to_bytes(result)
 
     return StreamingResponse(
         content=content(),
-        media_type="application/x-pandas-arrow",
+        media_type="application/octet-stream",
     )
 
 

src/phoenix/server/main.py

@@ -75,7 +75,7 @@
 
 _WELCOME_MESSAGE = Environment(loader=BaseLoader()).from_string("""
 
-██████╗ ██╗  ██╗ ██████╗ ███████╗███╗   ██╗██╗██╗  ██╗
+██████╗ ██╗  ██╗ ██████╗ ███████╗███╗   ██╗██╗██╗  ██╗ (managed by Arize)
 ██╔══██╗██║  ██║██╔═══██╗██╔════╝████╗  ██║██║╚██╗██╔╝
 ██████╔╝███████║██║   ██║█████╗  ██╔██╗ ██║██║ ╚███╔╝
 ██╔═══╝ ██╔══██║██║   ██║██╔══╝  ██║╚██╗██║██║ ██╔██╗

src/phoenix/session/client.py

@@ -193,6 +193,7 @@ def query_spans(
             raise ValueError(response.content.decode())
         response.raise_for_status()
         source = BytesIO(response.content)
+        print(f"{response.headers=}")
         results = []
         while True:
             try: