another debug tweak
@@ -45,10 +45,12 @@ def _copy_btw_filesystems(input_opener, output_opener, BLOCK_SIZE=10_000_000):
target.write(data)
bytes_read += len(data)
elapsed = time.time() - start
- rate = int(bytes_read / elapsed)
+ throughput = int(bytes_read / elapsed)
if elapsed // interval >= log_count:
logger.debug(f"_copy_btw_filesystems total bytes copied: {bytes_read}")
- logger.debug(f"throughput over {round(elapsed/60, 2)} min: ~{rate} bytes/sec")
+ logger.debug(
+ f"avg throughput over {round(elapsed/60, 2)} min: ~{throughput} bytes/sec"
+ )
log_count += 1
logger.debug("_copy_btw_filesystems done")
