Taragolis opened a new issue, #34844:
URL: https://github.com/apache/airflow/issues/34844

   ### Body
   
   There is couple issues happen if something went wrong during cluster 
creation. 
   
   We try to delete cluster by defer triggerer `EksDeleteClusterTrigger` to 
method `execute_failed`
   
https://github.com/apache/airflow/blob/609eed90698aa7abeb5bae9ae156062d32baae86/airflow/providers/amazon/aws/operators/eks.py#L338-L352
   
   However `execute_failed` method tried to validate incorrect status (typo in 
`delteted`)
   
https://github.com/apache/airflow/blob/609eed90698aa7abeb5bae9ae156062d32baae86/airflow/providers/amazon/aws/operators/eks.py#L399-L405
   
   This triggerer only returns status of execution and not exception, I guess 
we can't serialise exception object. 
   
https://github.com/apache/airflow/blob/609eed90698aa7abeb5bae9ae156062d32baae86/airflow/providers/amazon/aws/triggers/eks.py#L139
   
   Required to fix current error handling in `EksDeleteClusterTrigger` in 
deferrable mode. Seems like it could return success status even if execution 
failed, so I guess we need always raise an error in `execute_failed` method
   
   ### Committer
   
   - [X] I acknowledge that I am a maintainer/committer of the Apache Airflow 
project.


-- 
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]

Reply via email to