hankehly commented on code in PR #26003:
URL: https://github.com/apache/airflow/pull/26003#discussion_r962437210
##########
airflow/providers/amazon/aws/sensors/rds.py:
##########
@@ -149,7 +161,54 @@ def poke(self, context: 'Context'):
return self._check_item(item_type='export_task',
item_name=self.export_task_identifier)
+class RdsDbSensor(RdsBaseSensor):
Review Comment:
2022/09/05 update
(https://github.com/apache/airflow/pull/26003/commits/0d537b1bdf1fa3dbd8a94f1b635a5814e84e11e9)
Renamed `RdsInstanceSensor` to `RdsDbSensor` because it considers "cluster"
databases as well
##########
airflow/providers/amazon/aws/sensors/rds.py:
##########
@@ -149,7 +161,54 @@ def poke(self, context: 'Context'):
return self._check_item(item_type='export_task',
item_name=self.export_task_identifier)
+class RdsDbSensor(RdsBaseSensor):
+ """
+ Waits for an RDS instance or cluster to enter one of a number of states
+
+ .. seealso::
+ For more information on how to use this sensor, take a look at the
guide:
+ :ref:`howto/sensor:RdsDbSensor`
+
+ :param db_type: Type of the DB - either "instance" or "cluster"
+ :param db_identifier: The AWS identifier for the DB
+ :param target_statuses: Target status of DB
+ """
+
+ def __init__(
+ self,
+ *,
+ db_identifier: str,
+ db_type: str = RdsDbType.INSTANCE,
Review Comment:
2022/09/05 update
(https://github.com/apache/airflow/pull/26003/commits/0d537b1bdf1fa3dbd8a94f1b635a5814e84e11e9)
Added `db_type`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
