fix: on cluster for the creation of the staged del events table (Post…

…Hog#28164)
sloppyjuicy · Jan 31, 2025 · 1ab678a · 1ab678a
1 parent eaac7a4
commit 1ab678a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/deletes.py b/dags/deletes.py
@@ -167,7 +167,7 @@ def qualified_name(self):
     @property
     def create_table_query(self) -> str:
         return f"""
-            CREATE TABLE IF NOT EXISTS {self.qualified_name}
+            CREATE TABLE IF NOT EXISTS {self.qualified_name} ON CLUSTER '{self.cluster}'
             (
                 uuid UUID,
                 event String,