@@ -111,6 +111,7 @@ def _collect_ai_data(event, input_tokens, output_tokens, content_blocks):
111111 elif event .type == "message_delta" :
112112 output_tokens += event .usage .output_tokens
113113
114+ return input_tokens , output_tokens , content_blocks
114115
115116def _add_ai_data_to_span (
116117 span , integration , input_tokens , output_tokens , content_blocks
@@ -187,7 +188,7 @@ def new_iterator():
187188 content_blocks = [] # type: list[str]
188189
189190 for event in old_iterator :
190- _collect_ai_data (event , input_tokens , output_tokens , content_blocks )
191+ input_tokens , output_tokens , content_blocks = _collect_ai_data (event , input_tokens , output_tokens , content_blocks )
191192 if event .type != "message_stop" :
192193 yield event
193194
@@ -203,7 +204,7 @@ async def new_iterator_async():
203204 content_blocks = [] # type: list[str]
204205
205206 async for event in old_iterator :
206- _collect_ai_data (event , input_tokens , output_tokens , content_blocks )
207+ input_tokens , output_tokens , content_blocks = _collect_ai_data (event , input_tokens , output_tokens , content_blocks )
207208 if event .type != "message_stop" :
208209 yield event
209210
0 commit comments