Merge pull request #18 from tinybirdco/upload-by-hfi-instead-of-csv

ricardotinybird · web-flow · commit 4db9bb93abda · 2023-09-29T10:28:29.000+02:00
listen pending events and flush
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):
