@@ -696,37 +696,44 @@ def _stage_user_code_in_s3(self) -> str:
696
696
Returns: S3 URI
697
697
"""
698
698
if is_pipeline_variable (self .output_path ):
699
- code_bucket = self .sagemaker_session .default_bucket ()
700
699
if self .code_location is None :
700
+ code_bucket = self .sagemaker_session .default_bucket ()
701
701
code_s3_prefix = "{}/{}" .format (self ._current_job_name , "source" )
702
- kms_key = self .output_kms_key
703
- else :
704
- code_bucket , key_prefix = parse_s3_url (self .code_location )
705
- code_s3_prefix = "/" .join (
706
- filter (None , [key_prefix , self ._current_job_name , "source" ])
707
- )
708
- kms_key = (
709
- self .output_kms_key
710
- if code_bucket == self .sagemaker_session .default_bucket ()
711
- else None
712
- )
713
- else :
714
- if self .code_location is None :
715
- code_bucket , _ = parse_s3_url (self .output_path )
716
- code_s3_prefix = "{}/{}" .format (self ._current_job_name , "source" )
702
+ kms_key = None
717
703
else :
718
704
code_bucket , key_prefix = parse_s3_url (self .code_location )
719
705
code_s3_prefix = "/" .join (
720
706
filter (None , [key_prefix , self ._current_job_name , "source" ])
721
707
)
722
708
709
+ output_bucket = self .sagemaker_session .default_bucket ()
710
+ kms_key = self .output_kms_key if code_bucket == output_bucket else None
711
+ else :
723
712
local_mode = self .output_path .startswith ("file://" )
724
-
725
713
if local_mode :
726
- kms_key = None
714
+ if self .code_location is None :
715
+ code_bucket = self .sagemaker_session .default_bucket ()
716
+ code_s3_prefix = "{}/{}" .format (self ._current_job_name , "source" )
717
+ kms_key = None
718
+ else :
719
+ code_bucket , key_prefix = parse_s3_url (self .code_location )
720
+ code_s3_prefix = "/" .join (
721
+ filter (None , [key_prefix , self ._current_job_name , "source" ])
722
+ )
723
+ kms_key = None
727
724
else :
728
- output_bucket , _ = parse_s3_url (self .output_path )
729
- kms_key = self .output_kms_key if code_bucket == output_bucket else None
725
+ if self .code_location is None :
726
+ code_bucket , _ = parse_s3_url (self .output_path )
727
+ code_s3_prefix = "{}/{}" .format (self ._current_job_name , "source" )
728
+ kms_key = self .output_kms_key
729
+ else :
730
+ code_bucket , key_prefix = parse_s3_url (self .code_location )
731
+ code_s3_prefix = "/" .join (
732
+ filter (None , [key_prefix , self ._current_job_name , "source" ])
733
+ )
734
+
735
+ output_bucket , _ = parse_s3_url (self .output_path )
736
+ kms_key = self .output_kms_key if code_bucket == output_bucket else None
730
737
731
738
return tar_and_upload_dir (
732
739
session = self .sagemaker_session .boto_session ,
0 commit comments