Fix bug were SlowDown retries could result in BadDigest failures for …

…small files (#731)
fsspec · May 5, 2023 · f2425f0 · f2425f0
1 parent 9954eea
commit f2425f0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/s3fs/core.py b/s3fs/core.py
@@ -1107,8 +1107,9 @@ async def _put_file(
 
         with open(lpath, "rb") as f0:
             if size < min(5 * 2**30, 2 * chunksize):
+                chunk = f0.read()
                 await self._call_s3(
-                    "put_object", Bucket=bucket, Key=key, Body=f0, **kwargs
+                    "put_object", Bucket=bucket, Key=key, Body=chunk, **kwargs
                 )
                 callback.relative_update(size)
             else: