Skip to content

Commit dfc8543

Browse files
authored
Update bedrock.py
1 parent 4310e63 commit dfc8543

File tree

1 file changed

+4
-2
lines changed
  • instrumentation/opentelemetry-instrumentation-botocore/src/opentelemetry/instrumentation/botocore/extensions

1 file changed

+4
-2
lines changed

instrumentation/opentelemetry-instrumentation-botocore/src/opentelemetry/instrumentation/botocore/extensions/bedrock.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
from botocore.eventstream import EventStream
2929
from botocore.response import StreamingBody
3030

31+
from opentelemetry.context import get_current
3132
from opentelemetry.instrumentation.botocore.extensions.bedrock_utils import (
3233
ConverseStreamWrapper,
3334
InvokeModelWithResponseStreamWrapper,
@@ -67,6 +68,7 @@
6768
GEN_AI_CLIENT_OPERATION_DURATION,
6869
GEN_AI_CLIENT_TOKEN_USAGE,
6970
)
71+
from opentelemetry.trace.propagation import set_span_in_context
7072
from opentelemetry.trace.span import Span
7173
from opentelemetry.trace.status import Status, StatusCode
7274

@@ -505,8 +507,8 @@ def _converse_on_success(
505507
choice = _Choice.from_converse(result, capture_content)
506508
# this path is used by streaming apis, in that case we are already out of the span
507509
# context so need to add the span context manually
508-
span_ctx = span.get_span_context()
509-
logger.emit(choice.to_choice_event(context=span_ctx))
510+
context = set_span_in_context(span, get_current())
511+
logger.emit(choice.to_choice_event(context=context))
510512

511513
metrics = instrumentor_context.metrics
512514
metrics_attributes = self._extract_metrics_attributes()

0 commit comments

Comments
 (0)