diff --git a/ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/AddMetadata.java b/ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/AddMetadata.java index 8176f394a..3f8cc5f1f 100644 --- a/ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/AddMetadata.java +++ b/ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/AddMetadata.java @@ -42,7 +42,7 @@ public class AddMetadata { private static final String HEADER = "header"; private static final List HEADER_ATTRIBUTES = ImmutableList // - .of(Attribute.DATE, Attribute.DNT, Attribute.X_PINGSENDER_VERSION, Attribute.X_DEBUG_ID, + .of(Attribute.DATE, Attribute.DNT, Attribute.X_DEBUG_ID, Attribute.X_PINGSENDER_VERSION, Attribute.X_SOURCE_TAGS); private static final List URI_ATTRIBUTES = ImmutableList // diff --git a/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/AddMetadata.java b/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/AddMetadata.java index fcee3c2ae..4e5ccc33e 100644 --- a/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/AddMetadata.java +++ b/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/AddMetadata.java @@ -31,7 +31,8 @@ private AddMetadata() { private static final String HEADER = "header"; private static final List HEADER_ATTRIBUTES = ImmutableList // - .of(Attribute.DATE, Attribute.DNT, Attribute.X_DEBUG_ID, Attribute.X_PINGSENDER_VERSION); + .of(Attribute.DATE, Attribute.DNT, Attribute.X_DEBUG_ID, Attribute.X_PINGSENDER_VERSION, + Attribute.X_SOURCE_TAGS); private static final List URI_ATTRIBUTES = ImmutableList // .of(Attribute.URI, Attribute.APP_NAME, Attribute.APP_VERSION, Attribute.APP_UPDATE_CHANNEL,