code: def test_create_mapreduce_job_hook(self, create_operation_mock):
      self._init_hook()
  
      self.hook.client.create_mapreduce_job(
          archive_uris=None,
          args=[
              "-mapper",
              "mapper.py",
              "-reducer",
              "reducer.py",
              "-numReduceTasks",
              "1",
              "-input",
              "s3a://some-in-bucket/jobs/sources/data/cities500.txt.bz2",
              "-output",
              "s3a://some-out-bucket/dataproc/job/results",
          ],
          cluster_id="my_cluster_id",
          file_uris=[
              "s3a://some-in-bucket/jobs/sources/mapreduce-001/mapper.py",
              "s3a://some-in-bucket/jobs/sources/mapreduce-001/reducer.py",
          ],
          jar_file_uris=None,
          main_class="org.apache.hadoop.streaming.HadoopStreaming",
          main_jar_file_uri=None,
          name="Mapreduce job",
          properties={
              "yarn.app.mapreduce.am.resource.mb": "2048",
              "yarn.app.mapreduce.am.command-opts": "-Xmx2048m",
              "mapreduce.job.maps": "6",
          },
      )
      assert create_operation_mock.called
  
file_path: airflow/tests/providers/yandex/hooks/test_yandexcloud_dataproc.py
imports: from __future__ import annotations
  import json
  from unittest.mock import patch
  import pytest
  from airflow.models import Connection
label_desc: Use image node_id 6 for calling the TestYandexCloudDataprocHook obj's underlying member method code with example usage: obj.test_create_mapreduce_job_hook(create_operation_mock) without return types