docstr: Test Run Operator execute with correct parameters
docstr_tok: ["Test","Run","Operator","execute","with","correct","parameters"]
code: def test_execute(self, data_pipeline_hook_mock, run_operator):
      """
      Test Run Operator execute with correct parameters
      """
      run_operator.execute(mock.MagicMock())
      data_pipeline_hook_mock.assert_called_once_with(
          gcp_conn_id=TEST_GCP_CONN_ID,
      )
  
      data_pipeline_hook_mock.return_value.run_data_pipeline.assert_called_once_with(
          data_pipeline_name=TEST_DATA_PIPELINE_NAME,
          project_id=TEST_PROJECTID,
          location=TEST_LOCATION,
      )
  
file_path: airflow/tests/providers/google/cloud/operators/test_datapipeline.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.exceptions import AirflowException
  from airflow.providers.google.cloud.operators.datapipeline import CreateDataPipelineOperator, RunDataPipelineOperator
label_desc: Use image node_id 2 for calling the TestRunDataPipelineOperator obj's underlying member method code with example usage: obj.test_execute(data_pipeline_hook_mock, run_operator) without return types