Fix: fix the issue due to PR changes, 5122 (#5124)

* change: Allow telemetry only in supported regions

* change: Allow telemetry only in supported regions

* change: Allow telemetry only in supported regions

* change: Allow telemetry only in supported regions

* change: Allow telemetry only in supported regions

* documentation: Removed a line about python version requirements of training script which can misguide users.Training script can be of latest version based on the support provided by framework_version of the container

* feature: Enabled update_endpoint through model_builder

* fix: fix unit test, black-check, pylint errors

* fix: fix black-check, pylint errors

* fix:Added handler for pipeline variable while creating process job

* fix: Added handler for pipeline variable while creating process job

* Revert the PR changes: #5122, due to issue https://t.corp.amazon.com/P223568185/overview

* Fix: fix the issue, https://t.corp.amazon.com/P223568185/communication

---------

Co-authored-by: Roja Reddy Sareddy <[email protected]>

Author: rsareddy0329

src/sagemaker/processing.py

@@ -314,14 +314,15 @@ def _normalize_args(
                 "code argument has to be a valid S3 URI or local file path "
                 + "rather than a pipeline variable"
             )
+
         if arguments is not None:
             processed_arguments = []
             for arg in arguments:
                 if isinstance(arg, PipelineVariable):
                     processed_value = json.dumps(arg.expr)
                     processed_arguments.append(processed_value)
                 else:
-                    processed_arguments.append(str(arg))
+                    processed_arguments.append(arg)
             arguments = processed_arguments
 
         self._current_job_name = self._generate_current_job_name(job_name=job_name)

tests/unit/sagemaker/workflow/test_processing_step.py

@@ -824,12 +824,14 @@ def test_spark_processor(spark_processor, processing_input, pipeline_session):
     processor, run_inputs = spark_processor
     processor.sagemaker_session = pipeline_session
     processor.role = ROLE
+
     arguments_output = [
         "--input",
         "input-data-uri",
         "--output",
         '{"Get": "Parameters.MyArgOutput"}',
     ]
+
     run_inputs["inputs"] = processing_input
 
     step_args = processor.run(**run_inputs)
@@ -1024,6 +1026,7 @@ def test_spark_processor_local_code(spark_processor, processing_input, pipeline_
     processor, run_inputs = spark_processor
     processor.sagemaker_session = pipeline_session
     processor.role = ROLE
+
     arguments_output = [
         "--input",
         "input-data-uri",