fix: correct SSE stream endpoint path to unified API (#92)

* fix: correct SSE stream endpoint path to unified API

stream_execution_status used /api/v1/executions/{id}/stream instead of
/api/v1/unified/executions/{id}/stream, causing 404 when the server
only registers the unified endpoint.

* chore: bump version to 3.3.1

Author: saurabhjain1592

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to the AxonFlow Python SDK will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [3.3.1] - 2026-02-11
+
+### Fixed
+
+- `stream_execution_status()` used incorrect endpoint path (`/api/v1/executions/{id}/stream` → `/api/v1/unified/executions/{id}/stream`), causing 404 errors when streaming execution status updates
+
 ## [3.3.0] - 2026-02-10
 
 ### Added

axonflow/client.py

@@ -4469,7 +4469,7 @@ async def stream_execution_status(
     ) -> AsyncIterator[ExecutionStatus]:
         """Stream real-time execution status updates via Server-Sent Events (SSE).
 
-        Connects to GET /api/v1/executions/{execution_id}/stream and yields
+        Connects to GET /api/v1/unified/executions/{execution_id}/stream and yields
         ExecutionStatus objects as they arrive. The stream ends when a terminal
         status is received (completed, failed, cancelled, aborted, expired)
         or when the connection is closed.
@@ -4497,7 +4497,7 @@ async def stream_execution_status(
             msg = "Execution ID is required"
             raise ValueError(msg)
 
-        url = f"{self._config.endpoint}/api/v1/executions/{execution_id}/stream"
+        url = f"{self._config.endpoint}/api/v1/unified/executions/{execution_id}/stream"
 
         # Build headers for SSE
         headers = dict(self._http_client.headers)

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "axonflow"
-version = "3.3.0"
+version = "3.3.1"
 description = "AxonFlow Python SDK - Enterprise AI Governance in 3 Lines of Code"
 readme = "README.md"
 license = {text = "MIT"}

tests/test_execution_stream.py

@@ -70,7 +70,7 @@ async def test_stream_basic(
 
         sse_body = _build_sse_response(*events)
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -103,7 +103,7 @@ async def test_stream_server_error(
         from axonflow.exceptions import AxonFlowError
 
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/nonexistent/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/nonexistent/stream",
             status_code=404,
             content=b'{"error": "Execution not found"}',
         )
@@ -125,7 +125,7 @@ async def test_stream_sse_comments_ignored(
         sse_body = f": keep-alive\n\n\n\ndata: {json.dumps(event)}\n\n"
 
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -149,7 +149,7 @@ async def test_stream_invalid_json_skipped(
         sse_body = f"data: {{invalid json}}\n\ndata: {json.dumps(valid_event)}\n\n"
 
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -180,7 +180,7 @@ async def test_stream_failed_terminal(
 
         sse_body = _build_sse_response(*events)
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -208,7 +208,7 @@ async def test_stream_cancelled_terminal(
 
         sse_body = _build_sse_response(*events)
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -256,7 +256,7 @@ async def test_stream_with_steps(
 
         sse_body = _build_sse_response(event)
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -290,7 +290,7 @@ async def test_stream_map_plan_type(
 
         sse_body = _build_sse_response(event)
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )
@@ -317,7 +317,7 @@ async def test_stream_data_prefix_no_space(
         sse_body = f"data:{json.dumps(event)}\n\n"
 
         httpx_mock.add_response(
-            url="https://test.axonflow.com/api/v1/executions/exec_stream_1/stream",
+            url="https://test.axonflow.com/api/v1/unified/executions/exec_stream_1/stream",
             content=sse_body.encode(),
             headers={"Content-Type": "text/event-stream"},
         )