Skip to content

Commit

Permalink
feat: change log
Browse files Browse the repository at this point in the history
  • Loading branch information
furkan-bilgin committed Oct 12, 2024
1 parent b2a2f86 commit 183fd39
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions src/daq/store/csv.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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]

Expand Down

0 comments on commit 183fd39

Please sign in to comment.