code: def test_create_dataproc_cluster_mocked(self, create_operation_mock):
      self._init_hook()
  
      self.hook.client.create_cluster(
          cluster_name=CLUSTER_NAME,
          ssh_public_keys=SSH_PUBLIC_KEYS,
          folder_id=FOLDER_ID,
          subnet_id=SUBNET_ID,
          zone=AVAILABILITY_ZONE_ID,
          s3_bucket=S3_BUCKET_NAME_FOR_LOGS,
          cluster_image_version=CLUSTER_IMAGE_VERSION,
          service_account_id=SERVICE_ACCOUNT_ID,
      )
      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 3 for calling the TestYandexCloudDataprocHook obj's underlying member method code with example usage: obj.test_create_dataproc_cluster_mocked(create_operation_mock) without return types