ok

app/core/tidb_manager.py

@@ -165,8 +165,8 @@ class TiDBManager:
             inst = self.instances[idx]
             if inst.is_available and not inst.is_full:
                 logger.info(
-                    "Rotating TiDB write target: %s -> %s",
-                    self.instances[self._current_instance_index], inst,
+                    "Rotating TiDB write target: instance %d -> %d",
+                    self._current_instance_index + 1, idx + 1,
                 )
                 self._current_instance_index = idx
                 return True
@@ -272,7 +272,7 @@ class TiDBManager:
             return await self._try_write(query, params)
         except Exception as exc:
             if _is_storage_full_error(exc):
-                logger.warning("TiDB instance %s is full, rotating...", self.current_instance)
+                logger.warning("TiDB write target is full, rotating...")
                 self.current_instance.is_full = True
                 ok = await self.check_and_rotate()
                 if not ok:
@@ -284,7 +284,7 @@ class TiDBManager:
             raise
 
     async def execute_on_all(self, query: str, params=None):
-        for inst in self.instances:
+        for i, inst in enumerate(self.instances, 1):
             if not inst.is_available or not inst.pool:
                 continue
             try:
@@ -293,7 +293,7 @@ class TiDBManager:
                         await cur.execute(query, params or ())
                     await conn.commit()
             except Exception as exc:
-                logger.error("Error executing on %s: %s", inst, exc)
+                logger.error("Error executing on instance %d/%d: %s", i, len(self.instances), exc)
 
     async def insert_and_get_id(self, query: str, params=None) -> int:
         ok = await self.check_and_rotate()
@@ -303,7 +303,7 @@ class TiDBManager:
             return await self._try_write(query, params)
         except Exception as exc:
             if _is_storage_full_error(exc):
-                logger.warning("TiDB instance %s is full, rotating...", self.current_instance)
+                logger.warning("TiDB write target is full, rotating...")
                 self.current_instance.is_full = True
                 ok = await self.check_and_rotate()
                 if not ok: