diff --git a/s3fs/core.py b/s3fs/core.py
index 16f8f84a..9f6e0b52 100644
--- a/s3fs/core.py
+++ b/s3fs/core.py
@@ -1359,7 +1359,7 @@ async def _read_chunk(start, end):
                 **version_id_kw(version_id),
                 **kw,
             )
-            data = await resp["Body"].read()
+            data = await _error_wrapper(resp["Body"].read, retries=self.retries)
             resp["Body"].close()
             return start, data