@@ -220,7 +220,12 @@ def get_hub_model_version(
220
220
sagemaker_session = constants .DEFAULT_JUMPSTART_SAGEMAKER_SESSION
221
221
222
222
try :
223
- hub_content_summaries = _list_hub_content_versions_helper (hub_name = hub_name , hub_content_name = hub_model_name , hub_content_type = hub_model_type , sagemaker_session = sagemaker_session )
223
+ hub_content_summaries = _list_hub_content_versions_helper (
224
+ hub_name = hub_name ,
225
+ hub_content_name = hub_model_name ,
226
+ hub_content_type = hub_model_type ,
227
+ sagemaker_session = sagemaker_session ,
228
+ )
224
229
except Exception as ex :
225
230
raise Exception (f"Failed calling list_hub_content_versions: { str (ex )} " )
226
231
@@ -236,19 +241,28 @@ def get_hub_model_version(
236
241
return marketplace_hub_content_version
237
242
raise
238
243
239
- def _list_hub_content_versions_helper (hub_name , hub_content_name , hub_content_type , sagemaker_session ):
244
+
245
+ def _list_hub_content_versions_helper (
246
+ hub_name , hub_content_name , hub_content_type , sagemaker_session
247
+ ):
240
248
all_hub_content_summaries = []
241
249
list_hub_content_versions_response = sagemaker_session .list_hub_content_versions (
242
250
hub_name = hub_name , hub_content_name = hub_content_name , hub_content_type = hub_content_type
243
251
)
244
252
all_hub_content_summaries .extend (list_hub_content_versions_response .get ("HubContentSummaries" ))
245
253
while "NextToken" in list_hub_content_versions_response :
246
254
list_hub_content_versions_response = sagemaker_session .list_hub_content_versions (
247
- hub_name = hub_name , hub_content_name = hub_content_name , hub_content_type = hub_content_type , next_token = list_hub_content_versions_response ["NextToken" ]
248
- )
249
- all_hub_content_summaries .extend (list_hub_content_versions_response .get ("HubContentSummaries" ))
255
+ hub_name = hub_name ,
256
+ hub_content_name = hub_content_name ,
257
+ hub_content_type = hub_content_type ,
258
+ next_token = list_hub_content_versions_response ["NextToken" ],
259
+ )
260
+ all_hub_content_summaries .extend (
261
+ list_hub_content_versions_response .get ("HubContentSummaries" )
262
+ )
250
263
return all_hub_content_summaries
251
264
265
+
252
266
def _get_hub_model_version_for_open_weight_version (
253
267
hub_content_summaries : List [Any ], hub_model_version : Optional [str ] = None
254
268
) -> str :
0 commit comments