listen pending events and flush

ricardotinybird · ricardotinybird · commit d5f834646456 · 2023-09-29T10:27:51.000+02:00
diff --git a/clickhouse_mysql/pumper.py b/clickhouse_mysql/pumper.py
@@ -26,7 +26,7 @@ def __init__(self, reader=None, writer=None):
                 'UpdateRowsEvent': self.update_rows_event,
                 'DeleteRowsEvent': self.delete_rows_event,
                 # 'WriteRowsEvent.EachRow': self.write_rows_event_each_row,
-                # 'ReaderIdleEvent': self.reader_idle_event,
+                'ReaderIdleEvent': self.reader_idle_event,
             })
 
     def run(self):
