code: def test_execute(self, hook_mock, mock_xcom):
      parameters = {"param": "test"}
      hook_mock.return_value.run_query.return_value = {
          "key": {
              "queryId": QUERY_ID,
              "reportId": REPORT_ID,
          }
      }
      op = GoogleDisplayVideo360RunQueryOperator(
          query_id=QUERY_ID,
          parameters=parameters,
          api_version=API_VERSION,
          task_id="test_task",
      )
      op.execute(context=None)
      hook_mock.assert_called_once_with(
          gcp_conn_id=GCP_CONN_ID,
          delegate_to=None,
          api_version=API_VERSION,
          impersonation_chain=None,
      )
  
      mock_xcom.assert_any_call(None, key="query_id", value=QUERY_ID)
      mock_xcom.assert_any_call(None, key="report_id", value=REPORT_ID)
      hook_mock.return_value.run_query.assert_called_once_with(
          query_id=QUERY_ID, params=parameters
      )
  
imports: from __future__ import annotations
  import json
  from tempfile import NamedTemporaryFile
  from unittest import mock
  import pytest
  from airflow.exceptions import AirflowException
  from airflow.models import DAG, TaskInstance
  from airflow.providers.google.marketing_platform.operators.display_video import GoogleDisplayVideo360CreateQueryOperator, GoogleDisplayVideo360CreateSDFDownloadTaskOperator, GoogleDisplayVideo360DeleteReportOperator, GoogleDisplayVideo360DownloadLineItemsOperator, GoogleDisplayVideo360DownloadReportV2Operator, GoogleDisplayVideo360RunQueryOperator, GoogleDisplayVideo360SDFtoGCSOperator, GoogleDisplayVideo360UploadLineItemsOperator
  from airflow.utils import timezone
  from airflow.utils.session import create_session
label_desc: Use image node_id 1 for calling the TestGoogleDisplayVideo360RunQueryOperator obj's underlying member method code with example usage: obj.test_execute(hook_mock, mock_xcom) without return types