Skip to content

Commit d49e1cc

Browse files
committed
fix context datadog
1 parent fe9c763 commit d49e1cc

File tree

2 files changed

+12
-6
lines changed

2 files changed

+12
-6
lines changed

aws_lambda_powertools/tracing/provider/datadog/dd_tracer.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,13 +53,13 @@ def trace(
5353
span_type: Optional[str] = None,
5454
**kwargs,
5555
) -> Generator[DDSpan, None, None]:
56-
dd_span = self.dd_tracer.trace(
56+
with self.dd_tracer.trace(
5757
name=name,
5858
service=service,
5959
resource=resource,
6060
span_type=span_type,
61-
)
62-
yield DDSpan(dd_span=dd_span)
61+
) as dd_span:
62+
yield DDSpan(dd_span=dd_span)
6363

6464
in_subsegment = trace
6565

aws_lambda_powertools/tracing/tracer.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -348,13 +348,19 @@ def decorate(event, context, **kwargs):
348348
finally:
349349
global is_cold_start
350350
logger.debug("Annotating cold start")
351-
subsegment.put_annotation(key="ColdStart", value=is_cold_start)
351+
if not self._is_custom_provider():
352+
subsegment.put_annotation(key="ColdStart", value=is_cold_start)
353+
else:
354+
subsegment.set_attribute(key="ColdStart", value=is_cold_start)
352355

353356
if is_cold_start:
354357
is_cold_start = False
355358

356359
if self.service:
357-
subsegment.put_annotation(key="Service", value=self.service)
360+
if not self._is_custom_provider():
361+
subsegment.put_annotation(key="Service", value=self.service)
362+
else:
363+
subsegment.set_attribute(key="Service", value=self.service)
358364

359365
return response
360366

@@ -852,7 +858,7 @@ def _is_xray_provider(self):
852858
return isinstance(self.provider, XrayProvider)
853859

854860
def _is_custom_provider(self):
855-
return not self._is_xray_provider and isinstance(self.provider, BaseProvider)
861+
return not self._is_xray_provider() and isinstance(self.provider, BaseProvider)
856862

857863
def ignore_endpoint(self, hostname: Optional[str] = None, urls: Optional[List[str]] = None):
858864
"""If you want to ignore certain httplib requests you can do so based on the hostname or URL that is being

0 commit comments

Comments
 (0)