diff --git a/.github/workflows/docker-build-experimental.yml b/.github/workflows/docker-build-experimental.yml index 566efd63cb..934451f823 100644 --- a/.github/workflows/docker-build-experimental.yml +++ b/.github/workflows/docker-build-experimental.yml @@ -4,6 +4,7 @@ on: push: branches: - sessions + - managed-phoenix/test jobs: push_to_registry: diff --git a/src/phoenix/server/api/routers/v1/spans.py b/src/phoenix/server/api/routers/v1/spans.py index 37a7ef23d2..b4d2a41019 100644 --- a/src/phoenix/server/api/routers/v1/spans.py +++ b/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,6 +118,7 @@ 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: @@ -121,7 +126,7 @@ async def content() -> AsyncIterator[bytes]: return StreamingResponse( content=content(), - media_type="application/x-pandas-arrow", + media_type="application/octet-stream", ) diff --git a/src/phoenix/server/main.py b/src/phoenix/server/main.py index 7d00094136..7a13cb6a60 100644 --- a/src/phoenix/server/main.py +++ b/src/phoenix/server/main.py @@ -75,7 +75,7 @@ _WELCOME_MESSAGE = Environment(loader=BaseLoader()).from_string(""" -██████╗ ██╗ ██╗ ██████╗ ███████╗███╗ ██╗██╗██╗ ██╗ +██████╗ ██╗ ██╗ ██████╗ ███████╗███╗ ██╗██╗██╗ ██╗ (managed by Arize) ██╔══██╗██║ ██║██╔═══██╗██╔════╝████╗ ██║██║╚██╗██╔╝ ██████╔╝███████║██║ ██║█████╗ ██╔██╗ ██║██║ ╚███╔╝ ██╔═══╝ ██╔══██║██║ ██║██╔══╝ ██║╚██╗██║██║ ██╔██╗ diff --git a/src/phoenix/session/client.py b/src/phoenix/session/client.py index 906dbecf41..e3de760e4c 100644 --- a/src/phoenix/session/client.py +++ b/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: