fix: formatting

Author: Brock Wade

src/sagemaker/processing.py

@@ -1705,6 +1705,7 @@ def _pack_and_upload_code(
     ):
         """Pack local code bundle and upload to Amazon S3."""
         from sagemaker.workflow.utilities import _pipeline_config, hash_object
+
         if code.startswith("s3://"):
             return code, inputs, job_name
 

tests/data/framework_processor_data/evaluate.py

@@ -2,4 +2,4 @@
 Integ test file evaluate.py
 """
 
-print("test evaluate script")
+print("test evaluate script")

tests/data/framework_processor_data/preprocess.py

@@ -2,4 +2,4 @@
 Integ test file preprocess.py
 """
 
-print("test preprocess script")
+print("test preprocess script")

tests/data/framework_processor_data/query_data.py

@@ -2,4 +2,4 @@
 Integ test file query_data.py
 """
 
-print("test query data script")
+print("test query data script")

tests/data/framework_processor_data/train_test_split.py

@@ -2,4 +2,4 @@
 Integ test file train_test_split.py
 """
 
-print("test train, test, split script")
+print("test train, test, split script")

tests/integ/sagemaker/workflow/test_workflow.py

@@ -48,7 +48,7 @@
     ProcessingOutput,
     FeatureStoreOutput,
     ScriptProcessor,
-    FrameworkProcessor
+    FrameworkProcessor,
 )
 from sagemaker.s3 import S3Uploader
 from sagemaker.session import get_execution_role
@@ -86,7 +86,7 @@
     TransformInput,
     PropertyFile,
     TuningStep,
-    CacheConfig
+    CacheConfig,
 )
 from sagemaker.workflow.step_collections import RegisterModel
 from sagemaker.workflow.pipeline import Pipeline
@@ -1316,7 +1316,9 @@ def test_caching_behavior(
             pass
 
 
-def test_multi_step_framework_processing_pipeline_uploads(pipeline_session, role, pipeline_name, region_name):
+def test_multi_step_framework_processing_pipeline_uploads(
+    pipeline_session, role, pipeline_name, region_name
+):
     default_bucket = pipeline_session.default_bucket()
     cache_config = CacheConfig(enable_caching=True, expire_after="PT1H")
     evaluation_report = PropertyFile(
@@ -1419,16 +1421,17 @@ def test_multi_step_framework_processing_pipeline_uploads(pipeline_session, role
     )
 
     pipeline = Pipeline(
-        name=pipeline_name,
-        steps=[query_step, prepare_step, split_step, evaluate_step]
+        name=pipeline_name, steps=[query_step, prepare_step, split_step, evaluate_step]
     )
     try:
         pipeline.create(role)
 
         definition = json.loads(pipeline.definition())
 
-        source_dir_tar_prefix = f"s3://{default_bucket}/{pipeline_name}" \
+        source_dir_tar_prefix = (
+            f"s3://{default_bucket}/{pipeline_name}"
             f"/code/{hash_files_or_dirs([DATA_DIR + '/framework_processor_data'])}"
+        )
 
         run_procs = []
 
@@ -1448,4 +1451,4 @@ def test_multi_step_framework_processing_pipeline_uploads(pipeline_session, role
         try:
             pipeline.delete()
         except Exception:
-            pass
+            pass