Add seek(0) to request data to prevent issues on retries

fsspec · May 23, 2024 · 545e1a3 · 545e1a3
1 parent ac38bf3
commit 545e1a3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/gcsfs/core.py b/gcsfs/core.py
@@ -421,6 +421,8 @@ async def _request(
         self, method, path, *args, headers=None, json=None, data=None, **kwargs
     ):
         await self._set_session()
+        if hasattr(data, "seek"):
+            data.seek(0)
         async with self.session.request(
             method=method,
             url=self._format_path(path, args),