class_docstr: Module meant to test the DataPipeline Hooks
docstr: Test that request are called with the correct params
  Test that request returns the correct value
code: def test_create_data_pipeline(self, mock_connection):
      """
      Test that request are called with the correct params
      Test that request returns the correct value
      """
      mock_locations = (
          mock_connection.return_value.projects.return_value.locations
      )
      mock_request = (
          mock_locations.return_value.pipelines.return_value.create
      )
      mock_request.return_value.execute.return_value = {
          "name": TEST_PARENT
      }
  
      result = self.datapipeline_hook.create_data_pipeline(
          body=TEST_BODY,
          project_id=TEST_PROJECTID,
          location=TEST_LOCATION,
      )
  
      mock_request.assert_called_once_with(
          parent=TEST_PARENT,
          body=TEST_BODY,
      )
      assert result == {"name": TEST_PARENT}
  
file_path: airflow/tests/providers/google/cloud/hooks/test_datapipeline.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.providers.google.cloud.hooks.datapipeline import DataPipelineHook
label_desc: Use image node_id 4 for calling the TestDataPipelineHook obj's underlying member method code with example usage: obj.test_create_data_pipeline(mock_connection) without return types