Skip to content

Commit 6b124bc

Browse files
ci(anthropic): Include StreamedSpan in type annotations (#7373)
1 parent 692cca2 commit 6b124bc

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

‎sentry_sdk/integrations/anthropic.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@
8989
from sentry_sdk._types import TextPart
9090

9191
class _PatchedRawMessageStream(Stream[RawMessageStreamEvent]):
92-
_span: Span
92+
_span: Union[Span, StreamedSpan]
9393
_integration: "AnthropicIntegration"
9494

9595
_model: Optional[ModelParam]
@@ -99,7 +99,7 @@ class _PatchedRawMessageStream(Stream[RawMessageStreamEvent]):
9999
_finish_reason: Optional[str]
100100

101101
class _PatchedMessageStream(MessageStream):
102-
_span: Span
102+
_span: Union[Span, StreamedSpan]
103103
_integration: "AnthropicIntegration"
104104

105105
_model: Optional[ModelParam]
@@ -109,7 +109,7 @@ class _PatchedMessageStream(MessageStream):
109109
_finish_reason: Optional[str]
110110

111111
class _PatchedRawAsyncMessageStream(AsyncStream[RawMessageStreamEvent]):
112-
_span: Span
112+
_span: Union[Span, StreamedSpan]
113113
_integration: "AnthropicIntegration"
114114

115115
_model: Optional[ModelParam]
@@ -119,7 +119,7 @@ class _PatchedRawAsyncMessageStream(AsyncStream[RawMessageStreamEvent]):
119119
_finish_reason: Optional[str]
120120

121121
class _PatchedAsyncMessageStream(AsyncMessageStream):
122-
_span: Span
122+
_span: Union[Span, StreamedSpan]
123123
_integration: "AnthropicIntegration"
124124

125125
_model: Optional[ModelParam]
@@ -966,7 +966,7 @@ def _accumulate_event_data(
966966

967967

968968
def _set_streaming_output_data(
969-
span: "Span",
969+
span: "Union[Span, StreamedSpan]",
970970
integration: "AnthropicIntegration",
971971
model: "Optional[str]",
972972
usage: "_RecordedUsage",

0 commit comments

Comments
 (0)