code: def connect(
      host: str = "localhost",
      port: int = 9200,
      user: str | None = None,
      password: str | None = None,
      scheme: str = "http",
      **kwargs: Any,
  ) -> ESConnection:
      return ESConnection(host, port, user, password, scheme, **kwargs)
  
imports: from __future__ import annotations
  import warnings
  from functools import cached_property
  from typing import TYPE_CHECKING, Any
  from urllib import parse
  from elasticsearch import Elasticsearch
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.hooks.base import BaseHook
  from airflow.providers.common.sql.hooks.sql import DbApiHook
label_desc: Use image node_id 1 for calling a global function with example usage: connect(host, port, user, password, scheme) and returns: ESConnection