class_docstr: Base class for DataProc operators working with given cluster.
  
  :param connection_id: ID of the Yandex.Cloud Airflow connection.
  :param cluster_id: ID of the cluster to remove. (templated)
code: def _setup(self, context: Context) -> DataprocHook:
      if self.cluster_id is None:
          self.cluster_id = context["task_instance"].xcom_pull(
              key="cluster_id"
          )
      if self.yandex_conn_id is None:
          xcom_yandex_conn_id = context["task_instance"].xcom_pull(
              key="yandexcloud_connection_id"
          )
          if xcom_yandex_conn_id:
              warnings.warn(
                  "Implicit pass of `yandex_conn_id` is deprecated, please pass it explicitly"
              )
              self.yandex_conn_id = xcom_yandex_conn_id
  
      return DataprocHook(yandex_conn_id=self.yandex_conn_id)
  
imports: from __future__ import annotations
  import warnings
  from dataclasses import dataclass
  from typing import TYPE_CHECKING, Iterable, Sequence
  from airflow.models import BaseOperator
  from airflow.providers.yandex.hooks.yandexcloud_dataproc import DataprocHook
label_desc: Use image node_id 2 for calling the DataprocBaseOperator obj's underlying member method code with example usage: obj._setup(context) and returns: DataprocHook