Skip to content

Commit c6a06d8

Browse files
stainless-app[bot]stainless-app[bot]
committed
fix(streaming): add missing events
1 parent 7b03b0f commit c6a06d8

2 files changed

Lines changed: 41 additions & 1 deletion

File tree

‎.stats.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
configured_endpoints: 72
22
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/anthropic%2Fanthropic-dfe504526eed07979685a729ac9afd45e59cc2879291714b9f4674f2ef1247c7.yml
33
openapi_spec_hash: d849fdf2c4dd6631a60c4340e9bc1322
4-
config_hash: 831f90480c5b2b863b726e89eabaa90c
4+
config_hash: 127053e0220d5d31aef47d21169f9f6c

‎src/anthropic/_streaming.py‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,26 @@ def __stream__(self) -> Iterator[_T]:
9393
or sse.event == "content_block_delta"
9494
or sse.event == "content_block_stop"
9595
or sse.event == "message"
96+
or sse.event == "user.message"
97+
or sse.event == "user.interrupt"
98+
or sse.event == "user.tool_confirmation"
99+
or sse.event == "user.custom_tool_result"
100+
or sse.event == "agent.message"
101+
or sse.event == "agent.thinking"
102+
or sse.event == "agent.tool_use"
103+
or sse.event == "agent.tool_result"
104+
or sse.event == "agent.mcp_tool_use"
105+
or sse.event == "agent.mcp_tool_result"
106+
or sse.event == "agent.custom_tool_use"
107+
or sse.event == "agent.thread_context_compacted"
108+
or sse.event == "session.status_running"
109+
or sse.event == "session.status_idle"
110+
or sse.event == "session.status_rescheduled"
111+
or sse.event == "session.status_terminated"
112+
or sse.event == "session.error"
113+
or sse.event == "session.deleted"
114+
or sse.event == "span.model_request_start"
115+
or sse.event == "span.model_request_end"
96116
):
97117
data = sse.json()
98118
if is_dict(data) and "type" not in data:
@@ -214,6 +234,26 @@ async def __stream__(self) -> AsyncIterator[_T]:
214234
or sse.event == "content_block_delta"
215235
or sse.event == "content_block_stop"
216236
or sse.event == "message"
237+
or sse.event == "user.message"
238+
or sse.event == "user.interrupt"
239+
or sse.event == "user.tool_confirmation"
240+
or sse.event == "user.custom_tool_result"
241+
or sse.event == "agent.message"
242+
or sse.event == "agent.thinking"
243+
or sse.event == "agent.tool_use"
244+
or sse.event == "agent.tool_result"
245+
or sse.event == "agent.mcp_tool_use"
246+
or sse.event == "agent.mcp_tool_result"
247+
or sse.event == "agent.custom_tool_use"
248+
or sse.event == "agent.thread_context_compacted"
249+
or sse.event == "session.status_running"
250+
or sse.event == "session.status_idle"
251+
or sse.event == "session.status_rescheduled"
252+
or sse.event == "session.status_terminated"
253+
or sse.event == "session.error"
254+
or sse.event == "session.deleted"
255+
or sse.event == "span.model_request_start"
256+
or sse.event == "span.model_request_end"
217257
):
218258
data = sse.json()
219259
if is_dict(data) and "type" not in data:

0 commit comments

Comments
 (0)