Forgot commit

kolya7k · web-flow · commit eeeda3c873ce · 2025-02-06T10:43:03.000+05:00
diff --git a/mysql_ch_replicator/clickhouse_api.py b/mysql_ch_replicator/clickhouse_api.py
@@ -241,7 +241,7 @@ def insert(self, table_name, records, table_structure: TableStructure = None):
             table_name=table_name,
             duration=duration,
             is_insert=True,
-            records=len(records_to_insert),
+            records=len(records),
         )
 
         self.set_last_used_version(table_name, current_version)

Original file line number	Diff line number	Diff line change
`@@ -241,7 +241,7 @@ def insert(self, table_name, records, table_structure: TableStructure = None):`
`241`	`241`	`table_name=table_name,`
`242`	`242`	`duration=duration,`
`243`	`243`	`is_insert=True,`
`244`		`- records=len(records_to_insert),`
	`244`	`+ records=len(records),`
`245`	`245`	`)`
`246`	`246`
`247`	`247`	`self.set_last_used_version(table_name, current_version)`