Skip to content

Commit e34424e

Browse files
committed
dont hardcode streaming parameter
1 parent b6346a3 commit e34424e

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

sentry_sdk/integrations/cohere.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ def new_chat(*args: "Any", **kwargs: "Any") -> "Any":
178178
for k, v in COLLECTED_CHAT_PARAMS.items():
179179
if k in kwargs:
180180
set_data_normalized(span, v, kwargs[k])
181-
set_data_normalized(span, SPANDATA.GEN_AI_RESPONSE_STREAMING, False)
181+
set_data_normalized(span, SPANDATA.GEN_AI_RESPONSE_STREAMING, streaming)
182182

183183
if streaming:
184184
old_iterator = res

tests/integrations/cohere/test_cohere.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ def test_nonstreaming_chat(
7272
assert SPANDATA.GEN_AI_REQUEST_MESSAGES not in span["data"]
7373
assert SPANDATA.GEN_AI_RESPONSE_TEXT not in span["data"]
7474

75+
assert span["data"][SPANDATA.GEN_AI_RESPONSE_STREAMING] is False
7576
assert span["data"]["gen_ai.usage.output_tokens"] == 10
7677
assert span["data"]["gen_ai.usage.input_tokens"] == 20
7778
assert span["data"]["gen_ai.usage.total_tokens"] == 30
@@ -151,6 +152,7 @@ def test_streaming_chat(sentry_init, capture_events, send_default_pii, include_p
151152
assert SPANDATA.GEN_AI_REQUEST_MESSAGES not in span["data"]
152153
assert SPANDATA.GEN_AI_RESPONSE_TEXT not in span["data"]
153154

155+
assert span["data"][SPANDATA.GEN_AI_RESPONSE_STREAMING] is True
154156
assert span["data"]["gen_ai.usage.output_tokens"] == 10
155157
assert span["data"]["gen_ai.usage.input_tokens"] == 20
156158
assert span["data"]["gen_ai.usage.total_tokens"] == 30

0 commit comments

Comments
 (0)