Skip to content
4 changes: 2 additions & 2 deletions ddtrace/contrib/internal/avro/patch.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ def _traced_serialize(func, instance, args, kwargs):
active = pin.tracer.current_span()

try:
func(*args, **kwargs)
return func(*args, **kwargs)
finally:
if active:
SchemaExtractor.attach_schema_on_span(instance.writers_schema, active, SchemaExtractor.SERIALIZATION)
Expand All @@ -80,7 +80,7 @@ def _traced_deserialize(func, instance, args, kwargs):
active = pin.tracer.current_span()

try:
func(*args, **kwargs)
return func(*args, **kwargs)
finally:
reader = instance
if active and reader:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
---
fixes:
- |
avro: Fixes an issue where Avro instrumentation does not return method results when DSM is enabled.
Loading