We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6948e65 commit cca33a2Copy full SHA for cca33a2
src/sentry/spans/buffer.py
@@ -274,6 +274,11 @@ def flush_segments(
274
metrics.timing("sentry.spans.buffer.flush_segments.num_spans_per_segment", len(segment))
275
for payload in segment:
276
val = rapidjson.loads(payload)
277
+ old_segment_id = val.get("segment_id")
278
+ if old_segment_id:
279
+ val_data = val.setdefault("data", {})
280
+ if isinstance(val_data, dict):
281
+ val_data["__sentry_internal_old_segment_id"] = old_segment_id
282
val["segment_id"] = segment_span_id
283
val["is_segment"] = segment_span_id == val["span_id"]
284
return_segment.append(OutputSpan(payload=val))
0 commit comments