small fix

Bot-detector · Nov 26, 2023 · 42e443f · 42e443f
1 parent 4fa461f
commit 42e443f
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/main_v2.py b/src/main_v2.py
@@ -182,9 +182,10 @@ async def send_messages(topic: str, producer: AIOKafkaProducer, send_queue: Queu
 
     while True:
         if send_queue.empty():
-            start_time, messages_sent = log_speed(
-                counter=messages_sent, start_time=start_time, _queue=send_queue
-            )
+            if messages_sent > 0:
+                start_time, messages_sent = log_speed(
+                    counter=messages_sent, start_time=start_time, _queue=send_queue
+                )
             await asyncio.sleep(1)
             continue
         message = await send_queue.get()