code: def test_stop_task(
      self,
      mock_conn,
      mock_create_replication_task,
      mock_stop_replication_task,
      mock_get_task_status,
  ):
      dms_hook = DmsHook()
      task = dms_hook.create_replication_task(**self.TASK_DATA)
  
      stop_task = DmsStopTaskOperator(
          task_id="stop_task", replication_task_arn=task
      )
      stop_task.execute(None)
  
      mock_stop_replication_task.assert_called_once_with(
          replication_task_arn=TASK_ARN
      )
  
      assert dms_hook.get_task_status(TASK_ARN) == "stopping"
  
imports: from __future__ import annotations
  import json
  from unittest import mock
  import pendulum
  import pytest
  from airflow import DAG
  from airflow.models import DagRun, TaskInstance
  from airflow.providers.amazon.aws.hooks.dms import DmsHook
  from airflow.providers.amazon.aws.operators.dms import DmsCreateTaskOperator, DmsDeleteTaskOperator, DmsDescribeTasksOperator, DmsStartTaskOperator, DmsStopTaskOperator
  from airflow.utils import timezone
label_desc: Use image node_id 2 for calling the TestDmsStopTaskOperator obj's underlying member method code with example usage: obj.test_stop_task(mock_conn, mock_create_replication_task, mock_stop_replication_task, mock_get_task_status) without return types