feat(spans): Track when each span was received

CHANGELOG.md

@@ -11,6 +11,7 @@
 - Filter outliers (>180s) for mobile measurements. ([#2649](https://github.com/getsentry/relay/pull/2649))
 - Allow access to more context fields in dynamic sampling and metric extraction. ([#2607](https://github.com/getsentry/relay/pull/2607), [#2640](https://github.com/getsentry/relay/pull/2640), [#2675](https://github.com/getsentry/relay/pull/2675))
 - Allow advanced scrubbing expressions for datascrubbing safe fields. ([#2670](https://github.com/getsentry/relay/pull/2670))
+- Track when a span was received. ([#2688](https://github.com/getsentry/relay/pull/2688))
 - Add context for NEL (Network Error Logging) reports to the event schema. ([#2421](https://github.com/getsentry/relay/pull/2421))
 
 **Bug Fixes**:

relay-event-normalization/src/normalize/mod.rs

@@ -4000,6 +4000,7 @@ mod tests {
                 profile_id: ~,
                 data: ~,
                 sentry_tags: ~,
+                received: ~,
                 other: {},
             },
         ]
@@ -4040,6 +4041,7 @@ mod tests {
                 profile_id: ~,
                 data: ~,
                 sentry_tags: ~,
+                received: ~,
                 other: {},
             },
         ]
@@ -4080,6 +4082,7 @@ mod tests {
                 profile_id: ~,
                 data: ~,
                 sentry_tags: ~,
+                received: ~,
                 other: {},
             },
         ]

relay-event-schema/src/protocol/span.rs

@@ -73,6 +73,9 @@ pub struct Span {
     /// Tags generated by Relay. These tags are a superset of the tags set on span metrics.
     pub sentry_tags: Annotated<Object<String>>,
 
+    /// Timestamp when the span has been received by Sentry.
+    pub received: Annotated<Timestamp>,
+
     // TODO remove retain when the api stabilizes
     /// Additional arbitrary fields for forwards compatibility.
     #[metastructure(additional_properties, retain = "true", pii = "maybe")]
@@ -84,6 +87,7 @@ impl From<&Event> for Span {
         let mut span = Self {
             description: event.transaction.clone(),
             is_segment: Some(true).into(),
+            received: event.received.clone(),
             start_timestamp: event.start_timestamp.clone(),
             timestamp: event.timestamp.clone(),
             ..Default::default()
@@ -253,6 +257,7 @@ mod tests {
             ),
             data: ~,
             sentry_tags: ~,
+            received: ~,
             other: {},
         }
         "###);

relay-server/src/actors/processor.rs

@@ -2416,8 +2416,9 @@ impl EnvelopeProcessorService {
                 // HACK: clone the span to set the segment_id. This should happen
                 // as part of normalization once standalone spans reach wider adoption.
                 let mut new_span = inner_span.clone();
-                new_span.segment_id = transaction_span.segment_id.clone();
                 new_span.is_segment = Annotated::new(false);
+                new_span.received = transaction_span.received.clone();
+                new_span.segment_id = transaction_span.segment_id.clone();
 
                 // If a profile is associated with the transaction, also associate it with its
                 // child spans.

relay-server/src/metrics_extraction/event.rs

@@ -78,6 +78,7 @@ mod tests {
             "platform": "javascript",
             "start_timestamp": "2021-04-26T07:59:01+0100",
             "timestamp": "2021-04-26T08:00:00+0100",
+            "received": "2021-04-26T08:00:01+0100",
             "server_name": "myhost",
             "release": "1.2.3",
             "dist": "foo ",

relay-server/src/metrics_extraction/snapshots/relay_server__metrics_extraction__event__tests__extract_span_metrics_mobile.snap

@@ -36,6 +36,7 @@ expression: "(&event.value().unwrap().spans, metrics)"
                 "transaction": "gEt /api/:version/users/",
                 "transaction.method": "GET",
             },
+            received: ~,
             other: {},
         },
     ],

relay-server/src/metrics_extraction/transactions/mod.rs

@@ -571,6 +571,7 @@ mod tests {
                 profile_id: ~,
                 data: ~,
                 sentry_tags: ~,
+                received: ~,
                 other: {},
             },
         ]

tests/integration/test_store.py

@@ -1243,6 +1243,7 @@ def test_spans(
 
     child_span = spans_consumer.get_span()
     del child_span["start_time"]
+    del child_span["span"]["received"]
     assert child_span == {
         "event_id": "cbf6960622e14a45abc1f03b2055b186",
         "project_id": 42,
@@ -1272,6 +1273,7 @@ def test_spans(
 
     transaction_span = spans_consumer.get_span()
     del transaction_span["start_time"]
+    del transaction_span["span"]["received"]
     assert transaction_span == {
         "event_id": "cbf6960622e14a45abc1f03b2055b186",
         "project_id": 42,