code: def _get_expected_args(job_name, add_mock_input=False):
      args = {
          "inputs": [
              {
                  "InputName": "flow",
                  "AppManaged": False,
                  "S3Input": {
                      "S3Uri": DATA_WRANGLER_RECIPE_SOURCE,
                      "LocalPath": "/opt/ml/processing/flow",
                      "S3DataType": "S3Prefix",
                      "S3InputMode": "File",
                      "S3DataDistributionType": "FullyReplicated",
                      "S3CompressionType": "None",
                  },
              }
          ],
          "output_config": {"Outputs": []},
          "job_name": job_name,
          "resources": {
              "ClusterConfig": {
                  "InstanceType": "ml.m4.xlarge",
                  "InstanceCount": 1,
                  "VolumeSizeInGB": 30,
              }
          },
          "stopping_condition": None,
          "app_specification": {
              "ImageUri": DATA_WRANGLER_CONTAINER_URI,
          },
          "environment": None,
          "network_config": None,
          "role_arn": ROLE,
          "tags": None,
          "experiment_config": None,
      }
  
      if add_mock_input:
          mock_input = {
              "InputName": "mock_input",
              "AppManaged": False,
              "S3Input": {
                  "S3Uri": MOCK_S3_URI,
                  "LocalPath": "/opt/ml/processing/mock_input",
                  "S3DataType": "S3Prefix",
                  "S3InputMode": "File",
                  "S3DataDistributionType": "FullyReplicated",
                  "S3CompressionType": "None",
              },
          }
          args["inputs"].insert(0, mock_input)
      return 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 4 for calling a global function with example usage: _get_expected_args(job_name, add_mock_input) and returns: args