@@ -384,17 +384,14 @@ def download_folder(bucket_name, prefix, target, sagemaker_session):
384
384
sagemaker_session (sagemaker.session.Session): a sagemaker session to
385
385
interact with S3.
386
386
"""
387
- boto_session = sagemaker_session .boto_session
388
- s3 = boto_session .resource ("s3" , region_name = boto_session .region_name )
389
-
390
387
prefix = prefix .lstrip ("/" )
391
388
392
389
# Try to download the prefix as an object first, in case it is a file and not a 'directory'.
393
390
# Do this first, in case the object has broader permissions than the bucket.
394
391
if not prefix .endswith ("/" ):
395
392
try :
396
393
file_destination = os .path .join (target , os .path .basename (prefix ))
397
- s3 .Object (bucket_name , prefix ).download_file (file_destination )
394
+ sagemaker_session . s3_resource .Object (bucket_name , prefix ).download_file (file_destination )
398
395
return
399
396
except botocore .exceptions .ClientError as e :
400
397
err_info = e .response ["Error" ]
@@ -405,7 +402,7 @@ def download_folder(bucket_name, prefix, target, sagemaker_session):
405
402
else :
406
403
raise
407
404
408
- _download_files_under_prefix (bucket_name , prefix , target , s3 )
405
+ _download_files_under_prefix (bucket_name , prefix , target , sagemaker_session . s3_resource )
409
406
410
407
411
408
def _download_files_under_prefix (bucket_name , prefix , target , s3 ):
0 commit comments