RocksDBStorePartition: log a number of bytes written (#890)

daniil-quix · web-flow · commit 9fccc95d1eb7 · 2025-05-22T16:59:03.000+02:00
diff --git a/quixstreams/state/rocksdb/partition.py b/quixstreams/state/rocksdb/partition.py
@@ -126,7 +126,8 @@ def write(
         logger.debug(
             f"Flushing state changes to the disk "
             f'path="{self.path}" '
-            f"changelog_offset={changelog_offset}"
+            f"changelog_offset={changelog_offset} "
+            f"bytes_total={batch.size_in_bytes()}"
         )
 
         self._write(batch)

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,8 @@ def write(`
`126`	`126`	`logger.debug(`
`127`	`127`	`f"Flushing state changes to the disk "`
`128`	`128`	`f'path="{self.path}" '`
`129`		`- f"changelog_offset={changelog_offset}"`
	`129`	`+ f"changelog_offset={changelog_offset} "`
	`130`	`+ f"bytes_total={batch.size_in_bytes()}"`
`130`	`131`	`)`
`131`	`132`
`132`	`133`	`self._write(batch)`