diff --git a/docs/examples/python/highvolume_faster_queue.py b/docs/examples/python/highvolume_faster_queue.py
index 152223643e19d5c7f27b8f02f1819c2c0f2bd66b..a08de041774894e28c6ccd878c2aceee2b2dbe51 100644
--- a/docs/examples/python/highvolume_faster_queue.py
+++ b/docs/examples/python/highvolume_faster_queue.py
@@ -65,15 +65,11 @@ def run_write_task(task_id: int, queue: Queue):
     writer = SQLWriter(get_connection)
     lines = None
     try:
-        count = 0
         while True:
             try:
                 # get as many as possible
                 lines = queue.get_many(block=False, max_messages_to_get=MAX_BATCH_SIZE)
-                count += len(lines)
-                if count % 1000000 == 0:
-                    log.info(count)
-                # writer.process_lines(lines)
+                writer.process_lines(lines)
             except Empty:
                 time.sleep(0.01)
     except KeyboardInterrupt: