From fec91dc28385378290639852d90a59230e06087b Mon Sep 17 00:00:00 2001 From: dingbo Date: Thu, 14 Jul 2022 18:39:09 +0800 Subject: [PATCH] docs: test --- docs/examples/python/highvolume_faster_queue.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/docs/examples/python/highvolume_faster_queue.py b/docs/examples/python/highvolume_faster_queue.py index 152223643e..a08de04177 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: -- GitLab