Remove try-catch in fetch method let retry work (#313)

fsspec · Nov 26, 2024 · 732d935 · 732d935
1 parent 70d5157
commit 732d935
Showing 1 changed file with 9 additions and 12 deletions.
diff --git a/tosfs/core.py b/tosfs/core.py
@@ -2437,18 +2437,15 @@ def _fetch_range(self, start: int, end: int) -> bytes:
 
         def fetch() -> bytes:
             with io.BytesIO() as temp_buffer:
-                try:
-                    for chunk in self.fs.tos_client.get_object(
-                        self.bucket,
-                        self.key,
-                        self.version_id,
-                        range_start=start,
-                        range_end=end,
-                    ):
-                        temp_buffer.write(chunk)
-                    return temp_buffer.getvalue()
-                except Exception as e:
-                    raise TosClientError(f"{e}", e) from e
+                for chunk in self.fs.tos_client.get_object(
+                    self.bucket,
+                    self.key,
+                    self.version_id,
+                    range_start=start,
+                    range_end=end,
+                ):
+                    temp_buffer.write(chunk)
+                return temp_buffer.getvalue()
 
         return retryable_func_executor(fetch, max_retry_num=self.fs.max_retry_num)