code: def test_delete_cluster_operator(self, delete_cluster_mock, *_):
      operator = DataprocDeleteClusterOperator(
          task_id="delete_cluster",
          connection_id=CONNECTION_ID,
      )
      context = {"task_instance": MagicMock()}
      context["task_instance"].xcom_pull.return_value = "my_cluster_id"
      operator.execute(context)
      context["task_instance"].xcom_pull.assert_called_once_with(
          key="cluster_id"
      )
      delete_cluster_mock.assert_called_once_with("my_cluster_id")
  
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 3 for calling the TestDataprocClusterCreateOperator obj's underlying member method code with example usage: obj.test_delete_cluster_operator(delete_cluster_mock) without return types