fix: auto_flush_interval no longer reduces to flushing every row

Author: amunra

src/questdb/ingress.pyx

@@ -2432,6 +2432,8 @@ cdef class Sender:
             ok = line_sender_flush(sender, c_buf, &err)
         else:
             ok = line_sender_flush_and_keep(sender, c_buf, &err)
+        if ok and c_buf == self._buffer._impl:
+            self._last_flush_ms[0] = line_sender_now_micros() // 1000
         _ensure_has_gil(&gs)
         if not ok:
             if c_buf == self._buffer._impl:

test/test.py

@@ -823,6 +823,28 @@ def test_auto_flush_interval(self):
             # Due to CI timing delays there may have been multiple flushes.
             self.assertGreaterEqual(requests_len, 1)
 
+        def test_auto_flush_interval2(self):
+            with HttpServer() as server, self.builder(
+                    'http',
+                    'localhost',
+                    server.port,
+                    auto_flush_interval=10,
+                    auto_flush_rows=False,
+                    auto_flush_bytes=False) as sender:
+                sender.row('t', columns={'x': 1}, at=qi.ServerTimestamp)
+                sender.row('t', columns={'x': 2}, at=qi.ServerTimestamp)
+                time.sleep(0.02)
+                sender.row('t', columns={'x': 3}, at=qi.ServerTimestamp)
+                sender.row('t', columns={'x': 4}, at=qi.ServerTimestamp)
+                time.sleep(0.02)
+                sender.row('t', columns={'x': 5}, at=qi.ServerTimestamp)
+                sender.row('t', columns={'x': 6}, at=qi.ServerTimestamp)
+            self.assertEqual(len(server.requests), 3)
+            self.assertEqual(server.requests, [
+                b't x=1i\nt x=2i\nt x=3i\n',
+                b't x=4i\nt x=5i\n',
+                b't x=6i\n'])
+
         def test_http_username_password(self):
             with HttpServer() as server, self.builder('http', 'localhost', server.port, username='user',
                                                       password='pass') as sender: