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.
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 operator, take a look at the guide: DB snapshot sensor

Parameters

  • db_type (str) -- Type of the DB - either "instance" or "cluster"

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

  • target_statuses (Optional[List[str]]) -- Target status of snapshot

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

Function that the sensors defined while deriving this class should override.

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 operator, take a look at the guide: Export task sensor

Parameters

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

  • target_statuses (Optional[List[str]]) -- Target status of export task

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

Function that the sensors defined while deriving this class should override.

Was this entry helpful?