@@ -137,7 +137,7 @@ def precheck_index_naming(self):
137137 "it must start with an English letter, contain only letters, numbers, and underscores, and have a length of 1-128."
138138 )
139139
140- def _get_tos_client (self ) -> VeTOS :
140+ def _get_tos_client (self , tos_bucket_name : str ) -> VeTOS :
141141 volcengine_access_key = self .volcengine_access_key
142142 volcengine_secret_key = self .volcengine_secret_key
143143 session_token = self .session_token
@@ -153,7 +153,7 @@ def _get_tos_client(self) -> VeTOS:
153153 sk = volcengine_secret_key ,
154154 session_token = session_token ,
155155 region = self .tos_config .region ,
156- bucket_name = self .tos_config .bucket ,
156+ bucket_name = tos_bucket_name or self .tos_config .bucket ,
157157 )
158158
159159 @override
@@ -461,7 +461,7 @@ def _upload_bytes_to_tos(
461461 metadata : dict | None = None ,
462462 ) -> str :
463463 # Here, we set the metadata via the TOS object, ref: https://www.volcengine.com/docs/84313/1254624
464- self ._tos_client = self ._get_tos_client ()
464+ self ._tos_client = self ._get_tos_client (tos_bucket_name )
465465
466466 self ._tos_client .bucket_name = tos_bucket_name
467467 coro = self ._tos_client .upload (
0 commit comments