From 1e44b4b7af1fd62876f2028d2c32be153b47db44 Mon Sep 17 00:00:00 2001
From: "sentry-junior[bot]"
 <264270552+sentry-junior[bot]@users.noreply.github.com>
Date: Tue, 20 Oct 2026 20:16:00 +0000
Subject: [PATCH] feat(eap-items): Point eap_items_dlq_replay at eap_items_2
 tables

Co-Authored-By: Ryan Broughan <ryan.broughan@sentry.io>
---
 .../storages/eap_items_dlq_replay.yaml                | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

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 886a1e605ff..c629ef100ae 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: