code: def test_create_processing_job_invalid_processing_input(
      process, LocalSession
  ):
      local_sagemaker_client = (
          sagemaker.local.local_session.LocalSagemakerClient()
      )
  
      instance_count = 2
      image = "my-docker-image:1.0"
  
      app_spec = {"ImageUri": image}
      resource_config = {
          "ClusterConfig": {
              "InstanceCount": instance_count,
              "InstanceType": "local",
          }
      }
      environment = {"Var1": "Value1"}
      processing_inputs = [
          {
              "InputName": "input1",
              "DatasetDefinition": {
                  "AthenaDatasetDefinition": {
                      "Catalog": "cat1",
                      "Database": "db1",
                      "OutputS3Uri": "s3://bucket_name/prefix/",
                      "QueryString": "SELECT * FROM SOMETHING",
                  },
                  "DataDistributionType": "FullyReplicated",
                  "InputMode": "File",
                  "LocalPath": "/opt/ml/processing/input/athena",
              },
          }
      ]
      processing_output_config = {
          "Outputs": [
              {
                  "OutputName": "output1",
                  "S3Output": {
                      "LocalPath": "/opt/ml/processing/output/output1",
                      "S3Uri": "s3://some-bucket/some-path/output1",
                      "S3UploadMode": "Continuous",
                  },
              }
          ]
      }
      with pytest.raises(RuntimeError):
          local_sagemaker_client.create_processing_job(
              "my-processing-job",
              app_spec,
              resource_config,
              environment,
              processing_inputs,
              processing_output_config,
          )
  
imports: from __future__ import absolute_import
  import jsonschema
  import pytest
  import urllib3
  import os
  from botocore.exceptions import ClientError
  from mock import Mock, patch
  from tests.unit import DATA_DIR, SAGEMAKER_CONFIG_SESSION
  import sagemaker
  from sagemaker.workflow.parameters import ParameterString
  from sagemaker.workflow.pipeline import Pipeline
  from tests.unit.sagemaker.workflow.helpers import CustomStep
  from sagemaker.local.local_session import LocalSession
  from sagemaker.local.entities import _LocalPipelineExecution
label_desc: Use image node_id 4 for calling a global function with example usage: test_create_processing_job_invalid_processing_input(process, LocalSession) without return types