Temporarily remove delta

mattermost · Oct 18, 2024 · 5544f15 · 5544f15
1 parent 74e11be
commit 5544f15
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 29 deletions.
diff --git a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql
diff --git a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql
diff --git a/utils/db/__main__.py b/utils/db/__main__.py
@@ -96,6 +96,11 @@ def merge(
     delta_table: str,
     dedup_prune_days: int,
 ):
+    """
+    Helper to implement deferred merge on events table. Merges an event delta table to the base table.
+
+    Expects that base and delta tables have columns 'id', 'received_at' and 'after'.
+    """
     with ctx.obj['engine'].begin() as conn, conn.begin():
         merge_event_delta_table_into(
             conn,