docstr: Asserts that logging occurs as expected
docstr_tok: ["Asserts","that","logging","occurs","as","expected"]
code: def test_asynch_execute_logging_should_execute_successfully(self):
      """Asserts that logging occurs as expected"""
  
      op = CloudDataFusionStartPipelineOperator(
          task_id=TASK_ID,
          pipeline_name=PIPELINE_NAME,
          instance_name=INSTANCE_NAME,
          namespace=NAMESPACE,
          location=LOCATION,
          project_id=PROJECT_ID,
          runtime_args=RUNTIME_ARGS,
          deferrable=True,
      )
      with mock.patch.object(op.log, "info") as mock_log_info:
          op.execute_complete(
              context=mock.MagicMock(),
              event={
                  "status": "success",
                  "message": "Pipeline completed",
                  "pipeline_id": PIPELINE_ID,
              },
          )
      mock_log_info.assert_called_with(
          "%s completed with response %s ",
          TASK_ID,
          "Pipeline completed",
      )
  
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow import DAG
  from airflow.exceptions import AirflowException, TaskDeferred
  from airflow.providers.google.cloud.hooks.datafusion import SUCCESS_STATES, PipelineStates
  from airflow.providers.google.cloud.operators.datafusion import CloudDataFusionCreateInstanceOperator, CloudDataFusionCreatePipelineOperator, CloudDataFusionDeleteInstanceOperator, CloudDataFusionDeletePipelineOperator, CloudDataFusionGetInstanceOperator, CloudDataFusionListPipelinesOperator, CloudDataFusionRestartInstanceOperator, CloudDataFusionStartPipelineOperator, CloudDataFusionStopPipelineOperator, CloudDataFusionUpdateInstanceOperator
  from airflow.providers.google.cloud.triggers.datafusion import DataFusionStartPipelineTrigger
  from airflow.providers.google.cloud.utils.datafusion import DataFusionPipelineType
label_desc: Use image node_id 3 for calling the TestCloudDataFusionStartPipelineOperatorAsync obj's underlying member method code with example usage: obj.test_asynch_execute_logging_should_execute_successfully() without return types