chore: fix overwrite to append new migration when using generate cli (#…

…18939)
risingwavelabs · Oct 16, 2024 · a2b6f4f · a2b6f4f
1 parent e2a04af
commit a2b6f4f
Showing 1 changed file with 28 additions and 28 deletions.
diff --git a/src/meta/model_v2/migration/src/lib.rs b/src/meta/model_v2/migration/src/lib.rs
@@ -25,34 +25,6 @@ mod m20240911_083152_variable_vnode_count;
 
 pub struct Migrator;
 
-#[async_trait::async_trait]
-impl MigratorTrait for Migrator {
-    fn migrations() -> Vec<Box<dyn MigrationTrait>> {
-        vec![
-            Box::new(m20230908_072257_init::Migration),
-            Box::new(m20231008_020431_hummock::Migration),
-            Box::new(m20240304_074901_subscription::Migration),
-            Box::new(m20240410_082733_with_version_column_migration::Migration),
-            Box::new(m20240410_154406_session_params::Migration),
-            Box::new(m20240417_062305_subscription_internal_table_name::Migration),
-            Box::new(m20240418_142249_function_runtime::Migration),
-            Box::new(m20240506_112555_subscription_partial_ckpt::Migration),
-            Box::new(m20240525_090457_secret::Migration),
-            Box::new(m20240617_070131_index_column_properties::Migration),
-            Box::new(m20240617_071625_sink_into_table_column::Migration),
-            Box::new(m20240618_072634_function_compressed_binary::Migration),
-            Box::new(m20240630_131430_remove_parallel_unit::Migration),
-            Box::new(m20240701_060504_hummock_time_travel::Migration),
-            Box::new(m20240702_080451_system_param_value::Migration),
-            Box::new(m20240702_084927_unnecessary_fk::Migration),
-            Box::new(m20240726_063833_auto_schema_change::Migration),
-            Box::new(m20240806_143329_add_rate_limit_to_source_catalog::Migration),
-            Box::new(m20240820_081248_add_time_travel_per_table_epoch::Migration),
-            Box::new(m20240911_083152_variable_vnode_count::Migration),
-        ]
-    }
-}
-
 #[macro_export]
 macro_rules! assert_not_has_tables {
     ($manager:expr, $( $table:ident ),+) => {
@@ -84,3 +56,31 @@ macro_rules! drop_tables {
         )+
     };
 }
+
+#[async_trait::async_trait]
+impl MigratorTrait for Migrator {
+    fn migrations() -> Vec<Box<dyn MigrationTrait>> {
+        vec![
+            Box::new(m20230908_072257_init::Migration),
+            Box::new(m20231008_020431_hummock::Migration),
+            Box::new(m20240304_074901_subscription::Migration),
+            Box::new(m20240410_082733_with_version_column_migration::Migration),
+            Box::new(m20240410_154406_session_params::Migration),
+            Box::new(m20240417_062305_subscription_internal_table_name::Migration),
+            Box::new(m20240418_142249_function_runtime::Migration),
+            Box::new(m20240506_112555_subscription_partial_ckpt::Migration),
+            Box::new(m20240525_090457_secret::Migration),
+            Box::new(m20240617_070131_index_column_properties::Migration),
+            Box::new(m20240617_071625_sink_into_table_column::Migration),
+            Box::new(m20240618_072634_function_compressed_binary::Migration),
+            Box::new(m20240630_131430_remove_parallel_unit::Migration),
+            Box::new(m20240701_060504_hummock_time_travel::Migration),
+            Box::new(m20240702_080451_system_param_value::Migration),
+            Box::new(m20240702_084927_unnecessary_fk::Migration),
+            Box::new(m20240726_063833_auto_schema_change::Migration),
+            Box::new(m20240806_143329_add_rate_limit_to_source_catalog::Migration),
+            Box::new(m20240820_081248_add_time_travel_per_table_epoch::Migration),
+            Box::new(m20240911_083152_variable_vnode_count::Migration),
+        ]
+    }
+}