airflow.providers.amazon.aws.sensors.dms_task

Module Contents

class airflow.providers.amazon.aws.sensors.dms_task.DmsTaskBaseSensor(replication_task_arn: str, aws_conn_id='aws_default', target_statuses: Optional[Iterable[str]] = None, termination_statuses: Optional[Iterable[str]] = None, *args, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Contains general sensor behavior for DMS task.

Subclasses should set target_statuses and termination_statuses fields.

Parameters

  • replication_task_arn (str) -- AWS DMS replication task ARN

  • aws_conn_id (str) -- aws connection to uses

  • target_statuses -- the target statuses, sensor waits until the task reaches any of these states

  • termination_statuses (list[str]) -- the termination statuses, sensor fails when the task reaches any of these states

template_fields = ['replication_task_arn'][source]
template_ext = [][source]
get_hook(self)[source]

Get DmsHook

poke(self, context)[source]
class airflow.providers.amazon.aws.sensors.dms_task.DmsTaskCompletedSensor(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.sensors.dms_task.DmsTaskBaseSensor

Pokes DMS task until it is completed.

See also

For more information on how to use this operator, take a look at the guide: Create replication task, wait for it completion and delete it.

Parameters

replication_task_arn (str) -- AWS DMS replication task ARN

template_fields = ['replication_task_arn'][source]
template_ext = [][source]

Was this entry helpful?