ferruzzi commented on code in PR #32274:
URL: https://github.com/apache/airflow/pull/32274#discussion_r1253612171
##########
airflow/providers/amazon/aws/operators/ecs.py:
##########
@@ -139,13 +143,12 @@ def execute(self, context: Context):
self.log.info("Cluster %r in state: %r.", self.cluster_name,
cluster_state)
elif self.deferrable:
self.defer(
- trigger=ClusterWaiterTrigger(
- waiter_name="cluster_active",
+ trigger=ClusterActiveTrigger(
cluster_arn=cluster_details["clusterArn"],
Review Comment:
I'll buy that. We should keep a list somewhere of all these little "would
be nice in a BaseAwsOperator" things... I can never think of one big convincing
reason to put in the effort, but there have been a few smaller conveniences
here and there that I don't remember.
--
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]
