code: def test_data_wrangler_processor_with_required_parameters(
      sagemaker_session,
  ):
      processor = DataWranglerProcessor(
          role=ROLE,
          data_wrangler_flow_source=DATA_WRANGLER_RECIPE_SOURCE,
          instance_count=1,
          instance_type="ml.m4.xlarge",
          sagemaker_session=sagemaker_session,
      )
  
      processor.run()
      expected_args = _get_expected_args(processor._current_job_name)
      sagemaker_session.process.assert_called_with(**expected_args)
  
file_path: sagemaker-python-sdk/tests/unit/sagemaker/wrangler/test_processing.py
imports: from __future__ import absolute_import
  import pytest
  from mock import Mock, MagicMock
  from sagemaker.session_settings import SessionSettings
  from sagemaker.wrangler.processing import DataWranglerProcessor
  from sagemaker.processing import ProcessingInput
label_desc: Use image node_id 2 for calling a global function with example usage: test_data_wrangler_processor_with_required_parameters(sagemaker_session) without return types