From dd43b5e9c0dfeb81e8c1b13dac45b9a57974b689 Mon Sep 17 00:00:00 2001 From: Tom Forbes Date: Sun, 20 Oct 2024 12:56:35 +0100 Subject: [PATCH] Fix logging --- src/pypi_data/combine_parquet.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pypi_data/combine_parquet.py b/src/pypi_data/combine_parquet.py index 69cb57a0..7332c8d1 100644 --- a/src/pypi_data/combine_parquet.py +++ b/src/pypi_data/combine_parquet.py @@ -28,7 +28,7 @@ def append_buffer( writer.write_batch(batch) fd.flush() end_size = roll_up_path.stat().st_size - written_size = initial_size - end_size + written_size = end_size - initial_size log.info( f"Wrote {batch.num_rows} rows " f"Batch Size: {batch.nbytes / 1024 / 1024:.1f} MB "