code: def create_cluster_request(
      folder_id: str,
      cluster_name: str,
      cluster_desc: str,
      zone: str,
      subnet_id: str,
      service_account_id: str,
      ssh_public_key: str,
      resources: common_pb.Resources,
  ):
      return cluster_service_pb.CreateClusterRequest(
          folder_id=folder_id,
          name=cluster_name,
          description=cluster_desc,
          bucket=YC_S3_BUCKET_NAME,
          config_spec=cluster_service_pb.CreateClusterConfigSpec(
              hadoop=cluster_pb.HadoopConfig(
                  services=("SPARK", "YARN"),
                  ssh_public_keys=[ssh_public_key],
              ),
              subclusters_spec=[
                  cluster_service_pb.CreateSubclusterConfigSpec(
                      name="master",
                      role=subcluster_pb.Role.MASTERNODE,
                      resources=resources,
                      subnet_id=subnet_id,
                      hosts_count=1,
                  ),
                  cluster_service_pb.CreateSubclusterConfigSpec(
                      name="compute",
                      role=subcluster_pb.Role.COMPUTENODE,
                      resources=resources,
                      subnet_id=subnet_id,
                      hosts_count=1,
                  ),
              ],
          ),
          zone_id=zone,
          service_account_id=service_account_id,
      )
  
file_path: airflow/tests/system/providers/yandex/example_yandexcloud.py
imports: from __future__ import annotations
  import os
  from datetime import datetime
  import yandex.cloud.dataproc.v1.cluster_pb2
  import yandex.cloud.dataproc.v1.cluster_service_pb2
  import yandex.cloud.dataproc.v1.cluster_service_pb2_grpc
  import yandex.cloud.dataproc.v1.common_pb2
  import yandex.cloud.dataproc.v1.job_pb2
  import yandex.cloud.dataproc.v1.job_service_pb2
  import yandex.cloud.dataproc.v1.job_service_pb2_grpc
  import yandex.cloud.dataproc.v1.subcluster_pb2
  from google.protobuf.json_format import MessageToDict
  from airflow import DAG
  from airflow.decorators import task
  from airflow.providers.yandex.hooks.yandex import YandexCloudBaseHook
  from tests.system.utils import get_test_run
label_desc: Use image node_id 1 for calling a global function with example usage: create_cluster_request(folder_id, cluster_name, cluster_desc, zone, subnet_id, service_account_id, ssh_public_key, resources) and returns: cluster_service_pb