fix: added log count not reset in interval

Author: ErikKalkoken

src/vlogs_handler/__init__.py

@@ -3,4 +3,8 @@
 from .handler import VictoriaLogsHandler  # noqa: F401
 
 __title__ = "VictoriaLogs Handler"
-__version__ = "0.1.0dev5"
+__version__ = "0.1.0dev6"
+
+# TODO
+# [ ] - Split very large requests
+# [ ] - Consider using a persistent queue

src/vlogs_handler/handler.py

@@ -166,7 +166,6 @@ def emit(self, record: logging.LogRecord) -> None:
         with self._lock:
             self._added_count += 1
             if self._added_count > self._batch_size:
-                self._added_count = 0
                 self._worker_run.set()
 
     def _format_log_record(self, record: logging.LogRecord) -> Dict[str, Any]:
@@ -209,6 +208,8 @@ def start(self):
     def _worker(self):
         while not self._worker_shutdown.is_set():
             self._worker_run.wait(timeout=self._flush_interval)
+            with self._lock:
+                self._added_count = 0
             self.flush()
             self._worker_run.clear()