diff --git a/api/core/rag/datasource/vdb/tidb_on_qdrant/tidb_service.py b/api/core/rag/datasource/vdb/tidb_on_qdrant/tidb_service.py
index 0cc091a676..ece061db67 100644
--- a/api/core/rag/datasource/vdb/tidb_on_qdrant/tidb_service.py
+++ b/api/core/rag/datasource/vdb/tidb_on_qdrant/tidb_service.py
@@ -118,7 +118,9 @@ class TidbService:
                     qdrant_endpoint = TidbService.extract_qdrant_endpoint(cluster_response)
                     logger.info(
                         "Cluster %s is ACTIVE, user_prefix=%s, qdrant_endpoint=%s",
-                        cluster_id, user_prefix, qdrant_endpoint,
+                        cluster_id,
+                        user_prefix,
+                        qdrant_endpoint,
                     )
                     return {
                         "cluster_id": cluster_id,
@@ -127,7 +129,13 @@ class TidbService:
                         "password": password,
                         "qdrant_endpoint": qdrant_endpoint,
                     }
-                logger.info("Cluster %s state=%s, retry %d/%d", cluster_id, cluster_response["state"], retry_count + 1, max_retries)
+                logger.info(
+                    "Cluster %s state=%s, retry %d/%d",
+                    cluster_id,
+                    cluster_response["state"],
+                    retry_count + 1,
+                    max_retries,
+                )
                 time.sleep(30)
                 retry_count += 1
             logger.error("Cluster %s did not become ACTIVE after %d retries", cluster_id, max_retries)
@@ -304,12 +312,11 @@ class TidbService:
                 if not cached_password:
                     logger.warning("No cached password for cluster %s, skipping", item["displayName"])
                     continue
-                qdrant_endpoint = TidbService.fetch_qdrant_endpoint(
-                    api_url, public_key, private_key, item["clusterId"]
-                )
+                qdrant_endpoint = TidbService.fetch_qdrant_endpoint(api_url, public_key, private_key, item["clusterId"])
                 logger.info(
                     "Batch cluster %s: qdrant_endpoint=%s",
-                    item["clusterId"], qdrant_endpoint,
+                    item["clusterId"],
+                    qdrant_endpoint,
                 )
                 cluster_info = {
                     "cluster_id": item["clusterId"],