airflow.providers.amazon.aws.sensors.rds

Module Contents

Classes

RdsSnapshotExistenceSensor

Waits for RDS snapshot with a specific status.

RdsExportTaskExistenceSensor

Waits for RDS export task with a specific status.

RdsDbSensor

Waits for an RDS instance or cluster to enter one of a number of states.
class airflow.providers.amazon.aws.sensors.rds.RdsSnapshotExistenceSensor(*, db_type, db_snapshot_identifier, target_statuses=None, aws_conn_id='aws_conn_id', **kwargs)[source]

Bases: RdsBaseSensor

Waits for RDS snapshot with a specific status.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS snapshot status

Parameters

  • db_type (str) – Type of the DB - either “instance” or “cluster”

  • db_snapshot_identifier (str) – The identifier for the DB snapshot

  • target_statuses (list[str] | None) – Target status of snapshot

template_fields: collections.abc.Sequence[str] = ('db_snapshot_identifier', 'target_statuses')[source]
poke(context)[source]

Override when deriving this class.

class airflow.providers.amazon.aws.sensors.rds.RdsExportTaskExistenceSensor(*, export_task_identifier, target_statuses=None, aws_conn_id='aws_default', **kwargs)[source]

Bases: RdsBaseSensor

Waits for RDS export task with a specific status.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS export task status

Parameters

  • export_task_identifier (str) – A unique identifier for the snapshot export task.

  • target_statuses (list[str] | None) – Target status of export task

template_fields: collections.abc.Sequence[str] = ('export_task_identifier', 'target_statuses')[source]
poke(context)[source]

Override when deriving this class.

class airflow.providers.amazon.aws.sensors.rds.RdsDbSensor(*, db_identifier, db_type=RdsDbType.INSTANCE, target_statuses=None, aws_conn_id='aws_default', **kwargs)[source]

Bases: RdsBaseSensor

Waits for an RDS instance or cluster to enter one of a number of states.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS instance or cluster status

Parameters
template_fields: collections.abc.Sequence[str] = ('db_identifier', 'db_type', 'target_statuses')[source]
poke(context)[source]

Override when deriving this class.

Was this entry helpful?