Closed sarkch closed 2 months ago
Thanks for opening this, Looks like valid issue, able to re produce, these kind of errors validation is missing in async_wait. Will push the changes for this.
The AccessDeniedException log is i have added to produce what exact error waiter throwing :)
cc: @eladkal
Apache Airflow version
Other Airflow 2 version (please specify below)
If "Other Airflow 2 version" selected, which one?
2.8.1
What happened?
I am using StepFunctionStartExecutionOperator to execute a StateMachine.
if I look into the log of the task,
{{waiter_with_logging.py:129}} INFO - Status of step function execution is: {{waiter_with_logging.py:129}} INFO - Status of step function execution is: {{waiter_with_logging.py:129}} INFO - Status of step function execution is:
as you can see that airflow is not getting the current status (RUNNING, FAILED etc) of the StateMachine
What you think should happen instead?
Expected Output when the State Machine is RUNNING
How to reproduce
So in my case I found the root cause of this problem. The IAM Role associated with the Airflow did not have the below permission
On the StateMachine execution arn.
Before granting the permission
After Granting the permission
Operating System
Managed Airflow
Versions of Apache Airflow Providers
No response
Deployment
Amazon (AWS) MWAA
Deployment details
No response
Anything else?
No response
Are you willing to submit PR?
Code of Conduct