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]