class_docstr: Runs a query search against a given index on an OpenSearch cluster and returns results.
  
  .. seealso::
      For more information on how to use this operator, take a look at the guide:
      :ref:`howto/operator:OpenSearchQueryOperator`
  
  :param query: A Dictionary OpenSearch DSL query.
  :param search_object: A Search object from opensearch-dsl.
  :param index_name: The name of the index to search for documents.
  :param opensearch_conn_id: opensearch connection to use
  :param log_query: Whether to log the query used. Defaults to True and logs query used.
docstr: Executes a search against a given index or a Search object on an OpenSearch Cluster.
docstr_tok: ["Executes","a","search","against","a","given","index","or","a","Search","object","on","an","OpenSearch","Cluster","."]
code: def execute(self, context: Context) -> Any:
      """Executes a search against a given index or a Search object on an OpenSearch Cluster."""
      result = None
  
      if self.query is not None:
          if not self.query.get("query"):
              raise AirflowException(
                  "Query input is missing required field Query in dictionary"
              )
          if self.index_name is None:
              raise AirflowException(
                  "Index name is required when using the query input."
              )
          try:
              result = self.hook.search(
                  index_name=self.index_name, query=self.query
              )
          except OpenSearchException as e:
              raise AirflowException(e)
      elif self.search_object is not None:
          try:
              result = self.search_object.using(
                  self.hook.client
              ).execute()
          except OpenSearchException as e:
              raise AirflowException(e)
      else:
          raise AirflowException(
              """Input missing required input of query or search_object.
                  Either query or search_object is required."""
          )
      return result
  
imports: from __future__ import annotations
  from functools import cached_property
  from typing import TYPE_CHECKING, Any, Sequence
  from opensearchpy.exceptions import OpenSearchException
  from airflow.exceptions import AirflowException
  from airflow.models import BaseOperator
  from airflow.providers.opensearch.hooks.opensearch import OpenSearchHook
label_desc: Use image node_id 3 for calling the OpenSearchQueryOperator obj's underlying member method code with example usage: obj.execute(context) and returns: result