|
6 | 6 | from opentelemetry.context import Context |
7 | 7 | from opentelemetry.sdk.trace import ReadableSpan, SpanProcessor |
8 | 8 | from opentelemetry.trace import Span |
| 9 | +from opentelemetry.util.types import AttributeValue |
9 | 10 |
|
10 | 11 | logger = logging.getLogger(__name__) |
11 | 12 |
|
@@ -44,17 +45,17 @@ def __init__( |
44 | 45 | ) -> None: |
45 | 46 | self._baggage_key_predicate = baggage_key_predicate |
46 | 47 | self._override_keys = frozenset(override_keys) |
47 | | - self._pending: Dict[int, Dict[str, Any]] = {} |
| 48 | + self._pending: Dict[int, Dict[str, AttributeValue]] = {} |
48 | 49 |
|
49 | 50 | def on_start(self, span: Span, parent_context: Optional[Context] = None) -> None: |
50 | 51 | if not span.is_recording(): |
51 | 52 | return |
52 | 53 | all_baggage = get_all_baggage(parent_context) |
53 | 54 | for key, value in all_baggage.items(): |
54 | 55 | if self._baggage_key_predicate(key): |
55 | | - span.set_attribute(key, value) |
| 56 | + span.set_attribute(key, cast(AttributeValue, value)) |
56 | 57 |
|
57 | | - overrides = {k: all_baggage[k] for k in self._override_keys if k in all_baggage} |
| 58 | + overrides = {k: cast(AttributeValue, all_baggage[k]) for k in self._override_keys if k in all_baggage} |
58 | 59 | if overrides: |
59 | 60 | span_id = getattr(getattr(span, "context", None), "span_id", None) |
60 | 61 | if span_id is not None: |
|
0 commit comments