fix

xorbitsai · Mar 28, 2023 · 6734c25 · 6734c25
1 parent cb4d450
commit 6734c25
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/xorbits/_mars/services/storage/core.py b/python/xorbits/_mars/services/storage/core.py
@@ -641,6 +641,7 @@ async def upload_storage_info(self):
                             )
                     await self._cluster_api.set_band_storage_info.batch(*upload_tasks)
                     failure_num = 0
+                    await asyncio.sleep(1)
                 except asyncio.CancelledError:  # pragma: no cover
                     break
                 except (
@@ -651,7 +652,6 @@ async def upload_storage_info(self):
                     if failure_num >= 3:
                         # Exit the loop after three consecutive failures.
                         break
-                await asyncio.sleep(1)
 
     async def upload_disk_info(self):
         from ..cluster import DiskInfo