From 99bcd3dfc4bdf36a6b0122f8197531788fa559c6 Mon Sep 17 00:00:00 2001 From: Furkan Date: Tue, 15 Oct 2024 16:35:14 +0300 Subject: [PATCH] refactor: remove flush log --- src/daq/jobs/store/csv.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/daq/jobs/store/csv.py b/src/daq/jobs/store/csv.py index 9c9916c..d70da76 100644 --- a/src/daq/jobs/store/csv.py +++ b/src/daq/jobs/store/csv.py @@ -121,8 +121,8 @@ def store_loop(self): continue # Flush if the flush time is up - if self._flush(file): - self._logger.debug(f"Flushed '{file.file.name}' ({row_size} rows)") + self._flush(file) + for file_path in files_to_delete: del self._open_csv_files[file_path]