get_alter_table_statements -> get_alter_create_statements

Co-authored-by: James Greenhill <[email protected]>
PostHog · Aug 3, 2024 · d8e5e0d · d8e5e0d
1 parent 2e3032c
commit d8e5e0d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/posthog/clickhouse/migrations/0074_add_custom_and_features_property_groups.py b/posthog/clickhouse/migrations/0074_add_custom_and_features_property_groups.py
@@ -4,7 +4,7 @@
 operations = [
     run_sql_with_exceptions(statement)
     for statement in [
-        *sharded_events_property_groups.get_alter_table_statements("custom"),
-        *sharded_events_property_groups.get_alter_table_statements("feature_flags"),
+        *sharded_events_property_groups.get_alter_create_statements("custom"),
+        *sharded_events_property_groups.get_alter_create_statements("feature_flags"),
     ]
 ]
diff --git a/posthog/clickhouse/property_groups.py b/posthog/clickhouse/property_groups.py
@@ -24,7 +24,7 @@ def register(self, name: str, definition: PropertyGroupDefinition) -> None:
     def __get_map_expression(self, definition: PropertyGroupDefinition) -> str:
         return f"mapSort(mapFilter((key, _) -> {definition.filter_expression}, CAST(JSONExtractKeysAndValues({self.__source_column}, 'String'), 'Map(String, String)')))"
 
-    def get_alter_table_statements(self, name: str) -> Iterable[str]:
+    def get_alter_create_statements(self, name: str) -> Iterable[str]:
         column_name = f"{self.__source_column}_group_{name}"
         definition = self.__groups[name]
         return [