fix(clickhouse): update source table names

juspay · Jan 22, 2024 · 58d3a23 · 58d3a23
1 parent 1965e66
commit 58d3a23
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/crates/analytics/src/clickhouse.rs b/crates/analytics/src/clickhouse.rs
@@ -356,11 +356,11 @@ impl ToSql<ClickhouseClient> for AnalyticsCollection {
         match self {
             Self::Payment => Ok("payment_attempts".to_string()),
             Self::Refund => Ok("refunds".to_string()),
-            Self::SdkEvents => Ok("sdk_events".to_string()),
-            Self::ApiEvents => Ok("api_events".to_string()),
+            Self::SdkEvents => Ok("sdk_events_audit".to_string()),
+            Self::ApiEvents => Ok("api_events_audit".to_string()),
             Self::PaymentIntent => Ok("payment_intents".to_string()),
-            Self::ConnectorEvents => Ok("connector_events".to_string()),
-            Self::OutgoingWebhookEvent => Ok("outgoing_webhook_events".to_string()),
+            Self::ConnectorEvents => Ok("connector_events_audit".to_string()),
+            Self::OutgoingWebhookEvent => Ok("outgoing_webhook_events_audit".to_string()),
         }
     }
 }