code: def delete_cluster(
      cluster_id: str,
      yandex_conn_id: str | None = None,
  ):
      hook = YandexCloudBaseHook(yandex_conn_id=yandex_conn_id)
  
      operation = hook.sdk.client(
          cluster_service_grpc_pb.ClusterServiceStub
      ).Delete(
          cluster_service_pb.DeleteClusterRequest(cluster_id=cluster_id)
      )
      hook.sdk.wait_operation_and_get_result(
          operation,
          meta_type=cluster_service_pb.DeleteClusterMetadata,
      )
  
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 4 for calling a global function with example usage: delete_cluster(cluster_id, yandex_conn_id) without return types