Skip to content

Commit b6be46b

Browse files
committed
WIP
1 parent f0fcb28 commit b6be46b

File tree

2 files changed

+5
-20
lines changed

2 files changed

+5
-20
lines changed

Diff for: propagator/opentelemetry-propagator-aws-xray/src/opentelemetry/propagators/aws/aws_xray_propagator.py

+1-5
Original file line numberDiff line numberDiff line change
@@ -346,14 +346,10 @@ def extract(
346346
getter: Getter[CarrierT] = default_getter,
347347
) -> Context:
348348

349-
from ipdb import set_trace
350-
set_trace
351-
352349
xray_context = super().extract(carrier, context=context, getter=getter)
353350

354351
if trace.get_current_span(context=context).get_span_context().is_valid:
355-
# return xray_context
356-
pass
352+
return xray_context
357353

358354
trace_header = (
359355
environ.get(AWS_TRACE_HEADER_PROP) or

Diff for: propagator/opentelemetry-propagator-aws-xray/tests/test_aws_xray_lambda_propagator.py

+4-15
Original file line numberDiff line numberDiff line change
@@ -13,31 +13,23 @@
1313
# limitations under the License.
1414

1515
from unittest import TestCase
16-
from ipdb import set_trace
1716
from requests.structures import CaseInsensitiveDict
1817
from unittest.mock import patch
1918
from os import environ
20-
from opentelemetry.trace import (
21-
DEFAULT_TRACE_OPTIONS,
22-
DEFAULT_TRACE_STATE,
23-
SpanContext,
24-
)
2519
from opentelemetry.sdk.trace import ReadableSpan
2620
from opentelemetry.propagators.textmap import (
2721
DefaultGetter,
2822
)
2923
from opentelemetry.trace import (
3024
Link,
31-
set_span_in_context,
32-
NonRecordingSpan,
33-
TraceFlags,
3425
get_current_span,
3526
TraceState
3627
)
3728
from opentelemetry.context import get_current
3829

3930
from opentelemetry.propagators.aws.aws_xray_propagator import (
40-
AwsXrayLambdaPropagator
31+
AwsXrayLambdaPropagator,
32+
TRACE_HEADER_KEY
4133
)
4234

4335

@@ -93,24 +85,21 @@ def test_extract_from_environment_variable(self):
9385
}
9486
)
9587
def test_add_link_from_environment_variable(self):
96-
# TODO fix this test case
9788

9889
propagator = AwsXrayLambdaPropagator()
9990

10091
default_getter = DefaultGetter()
10192

10293
carrier = CaseInsensitiveDict(
10394
{
104-
# "_X_AMZN_TRACE_ID":
105-
# TODO figure out why when super() extract is being called the
106-
# link context is not what should be according to the java test
107-
"x-amzn-trace-id":
95+
TRACE_HEADER_KEY:
10896
(
10997
"Root=1-00000001-240000000000000000000001;"
11098
"Parent=1600000000000001;Sampled=1"
11199
)
112100
}
113101
)
102+
114103
extracted_context = propagator.extract(
115104
carrier,
116105
context=get_current(),

0 commit comments

Comments
 (0)