code: def test_create_mapreduce_job_operator(
      self, create_mapreduce_job_mock, *_
  ):
      operator = DataprocCreateMapReduceJobOperator(
          task_id="run_mapreduce_job",
          main_class="org.apache.hadoop.streaming.HadoopStreaming",
          file_uris=[
              "s3a://some-in-bucket/jobs/sources/mapreduce-001/mapper.py",
              "s3a://some-in-bucket/jobs/sources/mapreduce-001/reducer.py",
          ],
          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",
          ],
          properties={
              "yarn.app.mapreduce.am.resource.mb": "2048",
              "yarn.app.mapreduce.am.command-opts": "-Xmx2048m",
              "mapreduce.job.maps": "6",
          },
      )
      context = {"task_instance": MagicMock()}
      context["task_instance"].xcom_pull.return_value = "my_cluster_id"
      operator.execute(context)
  
      context["task_instance"].xcom_pull.assert_has_calls(
          [
              call(key="cluster_id"),
              call(key="yandexcloud_connection_id"),
          ]
      )
  
      create_mapreduce_job_mock.assert_called_once_with(
          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",
          },
      )
  
file_path: airflow/tests/providers/yandex/operators/test_yandexcloud_dataproc.py
imports: from __future__ import annotations
  import datetime
  from unittest.mock import MagicMock, call, patch
  from airflow.models.dag import DAG
  from airflow.providers.yandex.operators.yandexcloud_dataproc import DataprocCreateClusterOperator, DataprocCreateHiveJobOperator, DataprocCreateMapReduceJobOperator, DataprocCreatePysparkJobOperator, DataprocCreateSparkJobOperator, DataprocDeleteClusterOperator
label_desc: Use image node_id 5 for calling the TestDataprocClusterCreateOperator obj's underlying member method code with example usage: obj.test_create_mapreduce_job_operator(create_mapreduce_job_mock) without return types