Skip to content

Commit 81ca392

Browse files
committed
Fix erase statistics
1 parent 922021f commit 81ca392

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

mysql_ch_replicator/clickhouse_api.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,9 @@ def on_event(self, table_name: str, is_insert: bool, duration: float, records: i
6262
if is_insert:
6363
targets.append(self.general.inserts)
6464
targets.append(self.table_stats[table_name].inserts)
65+
else:
66+
targets.append(self.general.erases)
67+
targets.append(self.table_stats[table_name].erases)
6568

6669
for target in targets:
6770
target.duration += duration
@@ -253,7 +256,7 @@ def erase(self, table_name, field_name, field_values):
253256
self.stats.on_event(
254257
table_name=table_name,
255258
duration=duration,
256-
is_insert=True,
259+
is_insert=False,
257260
records=len(field_values),
258261
)
259262

0 commit comments

Comments
 (0)