class_docstr: Contains general sensor behavior for DMS task.
  
  Subclasses should set ``target_statuses`` and ``termination_statuses`` fields.
  
  :param replication_task_arn: AWS DMS replication task ARN
  :param target_statuses: the target statuses, sensor waits until
      the task reaches any of these states
  :param termination_statuses: the termination statuses, sensor fails when
      the task reaches any of these states
  :param aws_conn_id: The Airflow connection used for AWS credentials.
      If this is ``None`` or empty then the default boto3 behaviour is used. If
      running Airflow in a distributed manner and aws_conn_id is None or
      empty, then default boto3 configuration would be used (and must be
      maintained on each worker node).
  :param region_name: AWS region_name. If not specified then the default boto3 behaviour is used.
  :param verify: Whether or not to verify SSL certificates. See:
      https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
  :param botocore_config: Configuration dictionary (key-values) for botocore client. See:
      https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html
class_docstr_tok: ["Contains","general","sensor","behavior","for","DMS","task",".","Subclasses","should","set","``","target_statuses","``","and","``","termination_statuses","``","fields",".",":","param","replication_task_arn",":","AWS","DMS","replication","task","ARN",":","param","target_statuses",":","the","target","statuses",",","sensor","waits","until","the","task","reaches","any","of","these","states",":","param","termination_statuses",":","the","termination","statuses",",","sensor","fails","when","the","task","reaches","any","of","these","states",":","param","aws_conn_id",":","The","Airflow","connection","used","for","AWS","credentials",".","If","this","is","``","None","``","or","empty","then","the","default","boto3","behaviour","is","used",".","If","running","Airflow","in","a","distributed","manner","and","aws_conn_id","is","None","or","empty",",","then","default","boto3","configuration","would","be","used","(","and","must","be","maintained","on","each","worker","node",")",".",":","param","region_name",":","AWS","region_name",".","If","not","specified","then","the","default","boto3","behaviour","is","used",".",":","param","verify",":","Whether","or","not","to","verify","SSL","certificates",".","See",":","https",":","\/\/boto3.amazonaws.com\/v1\/documentation\/api\/latest\/reference\/core\/session.html",":","param","botocore_config",":","Configuration","dictionary","(","key-values",")","for","botocore","client",".","See",":","https",":","\/\/botocore.amazonaws.com\/v1\/documentation\/api\/latest\/reference\/config.html"]
code: def __init__(
      self,
      replication_task_arn: str,
      target_statuses: Iterable[str] | None = None,
      termination_statuses: Iterable[str] | None = None,
      **kwargs,
  ):
      super().__init__(**kwargs)
      self.replication_task_arn = replication_task_arn
      self.target_statuses: Iterable[str] = target_statuses or []
      self.termination_statuses: Iterable[str] = (
          termination_statuses or []
      )
  
file_path: airflow/airflow/providers/amazon/aws/sensors/dms.py
imports: from __future__ import annotations
  from typing import TYPE_CHECKING, Iterable, Sequence
  from deprecated import deprecated
  from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning, AirflowSkipException
  from airflow.providers.amazon.aws.hooks.dms import DmsHook
  from airflow.providers.amazon.aws.sensors.base_aws import AwsBaseSensor
  from airflow.providers.amazon.aws.utils.mixins import aws_template_fields
label_desc: Use image node_id 1 to create a new DmsTaskBaseSensor object from inherited base classes: AwsBaseSensor with example: obj = DmsTaskBaseSensor(replication_task_arn, target_statuses, termination_statuses)