@@ -233,6 +233,7 @@ def __init__(
233
233
self ._default_bucket_name_override = default_bucket
234
234
# this may also be set again inside :func:`_initialize` if it is None
235
235
self .default_bucket_prefix = default_bucket_prefix
236
+ self ._default_bucket_set_by_sdk = False
236
237
237
238
self .s3_resource = None
238
239
self .s3_client = None
@@ -542,24 +543,22 @@ def default_bucket(self):
542
543
543
544
region = self .boto_session .region_name
544
545
545
- _default_bucket_set_by_sdk = False
546
546
default_bucket = self ._default_bucket_name_override
547
547
if not default_bucket :
548
548
default_bucket = generate_default_sagemaker_bucket_name (self .boto_session )
549
- _default_bucket_set_by_sdk = True
549
+ self . _default_bucket_set_by_sdk = True
550
550
551
551
self ._create_s3_bucket_if_it_does_not_exist (
552
552
bucket_name = default_bucket ,
553
553
region = region ,
554
- default_bucket_set_by_sdk = _default_bucket_set_by_sdk ,
555
554
)
556
555
557
556
self ._default_bucket = default_bucket
558
557
559
558
return self ._default_bucket
560
559
561
560
def _create_s3_bucket_if_it_does_not_exist (
562
- self , bucket_name , region , default_bucket_set_by_sdk
561
+ self , bucket_name , region
563
562
):
564
563
"""Creates an S3 Bucket if it does not exist.
565
564
@@ -628,7 +627,7 @@ def _create_s3_bucket_if_it_does_not_exist(
628
627
else :
629
628
raise
630
629
631
- if default_bucket_set_by_sdk :
630
+ if self . _default_bucket_set_by_sdk :
632
631
# make sure the s3 bucket is configured in users account.
633
632
expected_bucket_owner_id = self .account_id ()
634
633
try :
@@ -641,7 +640,8 @@ def _create_s3_bucket_if_it_does_not_exist(
641
640
if error_code == "403" and message == "Forbidden" :
642
641
LOGGER .error (
643
642
"Since default_bucket param was not set, SageMaker Python SDK tried to use "
644
- "%s bucket. This bucket cannot be configured to use as it is not owned by Account %s. "
643
+ "%s bucket. "
644
+ "This bucket cannot be configured to use as it is not owned by Account %s. "
645
645
"To unblock it's recommended to use custom default_bucket "
646
646
"parameter in sagemaker.Session" ,
647
647
bucket_name ,
0 commit comments