syedahsn commented on code in PR #36079:
URL: https://github.com/apache/airflow/pull/36079#discussion_r1418032422
##########
airflow/providers/amazon/aws/operators/eks.py:
##########
@@ -400,9 +400,9 @@ def execute_failed(self, context: Context, event: dict[str,
Any] | None = None)
if event is None:
self.log.info("Trigger error: event is None")
raise AirflowException("Trigger error: event is None")
- elif event["status"] == "delteted":
+ elif event["status"] == "deleted":
self.log.info("Cluster deleted")
- raise event["exception"]
+ raise AirflowException("Error creating cluster")
Review Comment:
That's a good point. It shouldn't ever be the case that we don't get a
`deleted` status, but there's no reason not to move the exception out of the
block
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
