diff --git a/backend/windmill-api/src/job_helpers.rs b/backend/windmill-api/src/job_helpers.rs index 51b1c3606a..f75ceea226 100644 --- a/backend/windmill-api/src/job_helpers.rs +++ b/backend/windmill-api/src/job_helpers.rs @@ -876,11 +876,11 @@ impl AsyncRead for ProgressReadAdapter { match this.interval.poll_tick(cx) { Poll::Pending => {} Poll::Ready(_) => { - tracing::info!("read {} bytes for s3 upload", *this.interval_bytes * 10); + *this.total_bytes += *this.interval_bytes; + tracing::info!("uploaded {} bytes for s3 upload", *this.total_bytes); *this.interval_bytes = 0; } }; - *this.total_bytes += *this.interval_bytes; #[cfg(not(feature = "enterprise"))] if *this.total_bytes > 50 * 1024 * 1024 { diff --git a/python-client/wmill/wmill/s3_reader.py b/python-client/wmill/wmill/s3_reader.py index 9afcebcdbf..c7fce83df3 100644 --- a/python-client/wmill/wmill/s3_reader.py +++ b/python-client/wmill/wmill/s3_reader.py @@ -50,7 +50,7 @@ class S3BufferedReader(BufferedReader): def bytes_generator(buffered_reader: BufferedReader | BytesIO): while True: - byte = buffered_reader.read(1) + byte = buffered_reader.read(50 * 1024) if not byte: break yield byte