From 0dc2142100e52f847e7c9f427f39e0a331e62c53 Mon Sep 17 00:00:00 2001
From: extreme4all <>
Date: Tue, 2 Jan 2024 21:46:36 +0100
Subject: [PATCH] cleanup

---
 src/main.py | 12 ------------
 1 file changed, 12 deletions(-)

diff --git a/src/main.py b/src/main.py
index 5fb1c0a..1b16a09 100644
--- a/src/main.py
+++ b/src/main.py
@@ -25,18 +25,6 @@ async def insert_report(session: AsyncSession, data: dict):
     ...
 
 
-def log_speed(
-    counter: int, start_time: float, receive_queue: Queue
-) -> tuple[float, int]:
-    end_time = time.time()
-    delta_time = end_time - start_time
-    speed = counter / delta_time
-    logger.info(
-        f"qsize={receive_queue.qsize()}, processed {counter} in {delta_time:.2f} seconds, {speed:.2f} msg/sec"
-    )
-    return time.time(), 0
-
-
 # Define a function to process data from a queue
 async def process_data(receive_queue: Queue, error_queue: Queue):
     # Initialize counter and start time