feat: add telemetry emitter to ScriptProcessor and FrameworkProcessor run methods

sagemaker-core/src/sagemaker/core/processing.py

@@ -77,6 +77,8 @@
 from sagemaker.core.workflow.execution_variables import ExecutionVariables
 from sagemaker.core.workflow.functions import Join
 from sagemaker.core.workflow.pipeline_context import runnable_by_pipeline
+from sagemaker.core.telemetry.telemetry_logging import _telemetry_emitter
+from sagemaker.core.telemetry.constants import Feature
 
 from sagemaker.core._studio import _append_project_tags
 from sagemaker.core.config.config_utils import _append_sagemaker_config_tags
@@ -771,6 +773,7 @@ def __init__(
             network_config=network_config,
         )
 
+    @_telemetry_emitter(feature=Feature.PROCESSING, func_name="ScriptProcessor.run")
     @runnable_by_pipeline
     def run(
         self,
@@ -1171,6 +1174,7 @@ def _package_code(
             os.unlink(tmp.name)
             return s3_uri
 
+    @_telemetry_emitter(feature=Feature.PROCESSING, func_name="FrameworkProcessor.run")
     @runnable_by_pipeline
     def run(
         self,

sagemaker-core/src/sagemaker/core/telemetry/constants.py

@@ -29,6 +29,7 @@ class Feature(Enum):
     MODEL_CUSTOMIZATION = 15
     MLOPS = 16
     FEATURE_STORE = 17
+    PROCESSING = 18
 
     def __str__(self):  # pylint: disable=E0307
         """Return the feature name."""

sagemaker-core/src/sagemaker/core/telemetry/telemetry_logging.py

@@ -61,6 +61,7 @@
     str(Feature.MODEL_CUSTOMIZATION): 15,
     str(Feature.MLOPS): 16,
     str(Feature.FEATURE_STORE): 17,
+    str(Feature.PROCESSING): 18,
 }
 
 STATUS_TO_CODE = {