From 183fd39d0254322d3be4de08a1ae0f5fa5c16c46 Mon Sep 17 00:00:00 2001 From: Furkan Date: Sat, 12 Oct 2024 22:14:29 +0300 Subject: [PATCH] feat: change log --- src/daq/store/csv.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/daq/store/csv.py b/src/daq/store/csv.py index 5351068..f26d2fa 100644 --- a/src/daq/store/csv.py +++ b/src/daq/store/csv.py @@ -98,7 +98,6 @@ def store_loop(self): files_to_delete.append(file_path) continue writer = csv.writer(file.file) - total_rows_to_write = 0 rows_to_write = [] # Write rows in batches @@ -109,14 +108,11 @@ def store_loop(self): except Empty: break if len(rows_to_write) > 0: - total_rows_to_write += len(rows_to_write) writer.writerows(rows_to_write) # Flush if the flush time is up if self._flush(file): - self._logger.debug( - f"Flushed {total_rows_to_write} rows to '{file.file.name}'" - ) + self._logger.debug(f"Flushed '{file.file.name}'") for file_path in files_to_delete: del self._open_csv_files[file_path]