diff --git a/docs/edge/ar/learn/streaming-runtime-contract.mdx b/docs/edge/ar/learn/streaming-runtime-contract.mdx index 8bb4b7075..1107c1590 100644 --- a/docs/edge/ar/learn/streaming-runtime-contract.mdx +++ b/docs/edge/ar/learn/streaming-runtime-contract.mdx @@ -18,7 +18,6 @@ mode: "wide" ```python from crewai.types.streaming import StreamFrame -frame.version # "v1" frame.id # معرف إطار فريد frame.seq # ترتيب محلي للتنفيذ، عند توفره frame.type # نوع الحدث المصدر، مثل "flow_started" diff --git a/docs/edge/en/learn/streaming-runtime-contract.mdx b/docs/edge/en/learn/streaming-runtime-contract.mdx index 7497b6364..b7116d470 100644 --- a/docs/edge/en/learn/streaming-runtime-contract.mdx +++ b/docs/edge/en/learn/streaming-runtime-contract.mdx @@ -18,7 +18,6 @@ Every frame has the same envelope: ```python from crewai.types.streaming import StreamFrame -frame.version # "v1" frame.id # unique frame id frame.seq # execution-local order, when available frame.type # source event type, such as "flow_started" diff --git a/docs/edge/ko/learn/streaming-runtime-contract.mdx b/docs/edge/ko/learn/streaming-runtime-contract.mdx index 36b55b0ad..d216d1664 100644 --- a/docs/edge/ko/learn/streaming-runtime-contract.mdx +++ b/docs/edge/ko/learn/streaming-runtime-contract.mdx @@ -18,7 +18,6 @@ UI, 서비스 브리지, 터미널 앱, 배포 런타임을 만들 때 Flow, 채 ```python from crewai.types.streaming import StreamFrame -frame.version # "v1" frame.id # 고유 프레임 id frame.seq # 사용 가능한 경우 실행 로컬 순서 frame.type # "flow_started" 같은 원본 이벤트 타입 diff --git a/docs/edge/pt-BR/learn/streaming-runtime-contract.mdx b/docs/edge/pt-BR/learn/streaming-runtime-contract.mdx index 62b83edf5..3e4a758bb 100644 --- a/docs/edge/pt-BR/learn/streaming-runtime-contract.mdx +++ b/docs/edge/pt-BR/learn/streaming-runtime-contract.mdx @@ -18,7 +18,6 @@ Todo frame tem o mesmo envelope: ```python from crewai.types.streaming import StreamFrame -frame.version # "v1" frame.id # id único do frame frame.seq # ordem local da execução, quando disponível frame.type # tipo do evento de origem, como "flow_started" diff --git a/lib/crewai/src/crewai/types/streaming.py b/lib/crewai/src/crewai/types/streaming.py index 548a7e6ac..5115afa73 100644 --- a/lib/crewai/src/crewai/types/streaming.py +++ b/lib/crewai/src/crewai/types/streaming.py @@ -31,7 +31,6 @@ StreamChannel = Literal[ class StreamFrame(BaseModel): """Stable public stream frame emitted by streamable runtimes.""" - version: Literal["v1"] = "v1" id: str = Field(description="Unique frame/event identifier") seq: int | None = Field(default=None, description="Execution-local order") type: str = Field(description="Source event type") diff --git a/lib/crewai/src/crewai/utilities/streaming.py b/lib/crewai/src/crewai/utilities/streaming.py index 766fb00a8..93bf26de4 100644 --- a/lib/crewai/src/crewai/utilities/streaming.py +++ b/lib/crewai/src/crewai/utilities/streaming.py @@ -218,7 +218,6 @@ def stream_frame_from_event(event: BaseEvent) -> StreamFrame: if not isinstance(data, dict): data = {"value": data} return StreamFrame( - version="v1", id=event.event_id, seq=event.emission_sequence, type=event.type, diff --git a/lib/crewai/tests/test_stream_frames.py b/lib/crewai/tests/test_stream_frames.py index 1515b9453..5fc9ee168 100644 --- a/lib/crewai/tests/test_stream_frames.py +++ b/lib/crewai/tests/test_stream_frames.py @@ -95,7 +95,6 @@ def test_stream_frame_contract_and_ordering() -> None: assert stream.result == "done" assert all(isinstance(frame, StreamFrame) for frame in frames) - assert all(frame.version == "v1" for frame in frames) assert [frame.seq for frame in frames] == sorted(frame.seq for frame in frames) by_type = {frame.type: frame for frame in frames}