code: def test_create_spark_job_operator(self, create_spark_job_mock, *_):
      operator = DataprocCreateSparkJobOperator(
          task_id="create_spark_job",
          main_jar_file_uri="s3a://data-proc-public/jobs/sources/java/dataproc-examples-1.0.jar",
          main_class="ru.yandex.cloud.dataproc.examples.PopulationSparkJob",
          file_uris=[
              "s3a://some-in-bucket/jobs/sources/data/config.json",
          ],
          archive_uris=[
              "s3a://some-in-bucket/jobs/sources/data/country-codes.csv.zip",
          ],
          jar_file_uris=[
              "s3a://some-in-bucket/jobs/sources/java/icu4j-61.1.jar",
              "s3a://some-in-bucket/jobs/sources/java/commons-lang-2.6.jar",
              "s3a://some-in-bucket/jobs/sources/java/opencsv-4.1.jar",
              "s3a://some-in-bucket/jobs/sources/java/json-20190722.jar",
          ],
          args=[
              "s3a://some-in-bucket/jobs/sources/data/cities500.txt.bz2",
              "s3a://some-out-bucket/dataproc/job/results/${{JOB_ID}}",
          ],
          properties={
              "spark.submit.deployMode": "cluster",
          },
      )
      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_spark_job_mock.assert_called_once_with(
          archive_uris=[
              "s3a://some-in-bucket/jobs/sources/data/country-codes.csv.zip"
          ],
          args=[
              "s3a://some-in-bucket/jobs/sources/data/cities500.txt.bz2",
              "s3a://some-out-bucket/dataproc/job/results/${{JOB_ID}}",
          ],
          cluster_id="my_cluster_id",
          file_uris=[
              "s3a://some-in-bucket/jobs/sources/data/config.json"
          ],
          jar_file_uris=[
              "s3a://some-in-bucket/jobs/sources/java/icu4j-61.1.jar",
              "s3a://some-in-bucket/jobs/sources/java/commons-lang-2.6.jar",
              "s3a://some-in-bucket/jobs/sources/java/opencsv-4.1.jar",
              "s3a://some-in-bucket/jobs/sources/java/json-20190722.jar",
          ],
          main_class="ru.yandex.cloud.dataproc.examples.PopulationSparkJob",
          main_jar_file_uri="s3a://data-proc-public/jobs/sources/java/dataproc-examples-1.0.jar",
          name="Spark job",
          properties={"spark.submit.deployMode": "cluster"},
          packages=None,
          repositories=None,
          exclude_packages=None,
      )
  
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 6 for calling the TestDataprocClusterCreateOperator obj's underlying member method code with example usage: obj.test_create_spark_job_operator(create_spark_job_mock) without return types