Improve

Author: iambriccardo

etl-postgres/src/types/schema.rs

@@ -311,7 +311,10 @@ impl ReplicatedTableSchema {
     pub fn column_schemas(&self) -> impl Iterator<Item = &ColumnSchema> + Clone + '_ {
         // Assuming that the schema is created via the constructor, we can safely assume that the
         // column schemas and replication mask are of the same length.
-        debug_assert!(self.replication_mask.len() == self.table_schema.column_schemas.len());
+        debug_assert!(
+            self.replication_mask.len() == self.table_schema.column_schemas.len(),
+            "the replication mask columns have a different len from the table schema columns, they should be the same"
+        );
 
         self.table_schema
             .column_schemas

etl/migrations/20251127090000_schema_change_messages.sql

@@ -142,6 +142,10 @@ $$;
 
 drop event trigger if exists etl_ddl_message_trigger;
 
+-- Only ALTER TABLE is captured because:
+-- - CREATE TABLE: No need, since the initial schema is loaded during the first table copy operation.
+-- - DROP TABLE: No need, since dropped tables are not supported right now.
+-- This trigger focuses on schema changes to existing replicated tables.
 create event trigger etl_ddl_message_trigger
     on ddl_command_end
     when tag in ('ALTER TABLE')