refactor: remove flush log

ENRG-tr · Oct 15, 2024 · 99bcd3d · 99bcd3d
1 parent 1923e25
commit 99bcd3d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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]