code: def test_init(self):
      self.default_op_kwargs.pop("aws_conn_id", None)
  
      sensor = DmsTaskCompletedSensor(
          **self.default_op_kwargs,
          # Generic hooks parameters
          aws_conn_id="fake-conn-id",
          region_name="ca-west-1",
          verify=True,
          botocore_config={"read_timeout": 42},
      )
      assert sensor.hook.client_type == "dms"
      assert sensor.hook.resource_type is None
      assert sensor.hook.aws_conn_id == "fake-conn-id"
      assert sensor.hook._region_name == "ca-west-1"
      assert sensor.hook._verify is True
      assert sensor.hook._config is not None
      assert sensor.hook._config.read_timeout == 42
  
      sensor = DmsTaskCompletedSensor(
          task_id="create_task", replication_task_arn="task_arn"
      )
      assert sensor.hook.aws_conn_id == "aws_default"
      assert sensor.hook._region_name is None
      assert sensor.hook._verify is None
      assert sensor.hook._config is None
  
file_path: airflow/tests/providers/amazon/aws/sensors/test_dms.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.exceptions import AirflowException, AirflowSkipException
  from airflow.providers.amazon.aws.hooks.dms import DmsHook
  from airflow.providers.amazon.aws.sensors.dms import DmsTaskCompletedSensor
label_desc: Use image node_id 2 for calling the TestDmsTaskCompletedSensor obj's underlying member method code with example usage: obj.test_init() without return types