diff --git a/snuba/datasets/configuration/events_analytics_platform/storages/eap_items_dlq_replay.yaml b/snuba/datasets/configuration/events_analytics_platform/storages/eap_items_dlq_replay.yaml index 886a1e605f..c629ef100a 100644 --- a/snuba/datasets/configuration/events_analytics_platform/storages/eap_items_dlq_replay.yaml +++ b/snuba/datasets/configuration/events_analytics_platform/storages/eap_items_dlq_replay.yaml @@ -16,6 +16,9 @@ schema: { name: item_type, type: UInt, args: { size: 8 } }, { name: timestamp, type: DateTime }, { name: trace_id, type: UUID }, + { name: conversation_id, type: UUID }, + { name: session_id, type: UUID }, + { name: ai_conversation_id, type: String }, { name: item_id, type: UInt, args: { size: 128 } }, { name: sampling_weight, type: UInt, args: { size: 64 } }, { name: sampling_factor, type: Float, args: { size: 64 } }, @@ -112,15 +115,15 @@ schema: { name: attributes_array_float, type: Map, args: { key: { type: String }, value: { type: Array, args: { inner_type: { type: Float, args: { size: 64 } } } } } }, { name: attributes_array_bool, type: Map, args: { key: { type: String }, value: { type: Array, args: { inner_type: { type: Bool } } } } }, ] - local_table_name: eap_items_1_local - dist_table_name: eap_items_1_dist + local_table_name: eap_items_2_local + dist_table_name: eap_items_2_dist partition_format: [retention_days, date] query_processors: - processor: UniqInSelectAndHavingProcessor - processor: UUIDColumnProcessor args: - columns: [trace_id] + columns: [trace_id, conversation_id, session_id] - processor: HexIntColumnProcessor args: columns: [item_id] @@ -144,7 +147,7 @@ mandatory_condition_checkers: field_name: organization_id # Consumes from the eap_items DLQ topic and writes to the same ClickHouse -# tables as the primary `eap_items` storage. Intentionally has no +# tables as the primary `eap_items_2` storage. Intentionally has no # `dlq_topic`: messages that fail processing here will fail the consumer # loudly rather than getting silently re-DLQ'd back into the same topic. stream_loader: