Infra: introduce retry func warpper

fsspec · Sep 12, 2024 · 904c982 · 904c982
1 parent f95a4f3
commit 904c982
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tosfs/core.py b/tosfs/core.py
@@ -472,7 +472,7 @@ def mkdir(self, path: str, create_parents: bool = True, **kwargs: Any) -> None:
                 raise FileNotFoundError(f"Parent directory {parent} does not exist.")
             else:
                 retryable_func(
-                    self.tos_client.put_object(bucket, key.rstrip("/") + "/"),
+                    lambda: self.tos_client.put_object(bucket, key.rstrip("/") + "/"),
                     max_retry_num=self.max_retry_num,
                 )