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

   ### Apache Airflow Provider(s)
   
   amazon
   
   ### Versions of Apache Airflow Providers
   
   2.8.1
   
   ### Apache Airflow version
   
   2.8.1
   
   ### Operating System
   
   Managed Airflow
   
   ### Deployment
   
   Amazon (AWS) MWAA
   
   ### Deployment details
   
   _No response_
   
   ### What happened
   
   I am using `StepFunctionStartExecutionOperator`  to execute a StateMachine.
   
   ```
   StepFunctionStartExecutionOperator(
   ...
   task_id="load_data",
   deferrable=True,
   waiter_delay=30,  # Poll for every 30 seconds
   waiter_max_attempts=10,  # maximum number of attempts to poll for status
   do_xcom_push=True,
   )
   ```
   
   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
   
   ```
   [2024-08-28, 17:01:06 UTC] {{waiter_with_logging.py:129}} INFO - Status of 
step function execution is: RUNNING
   [2024-08-28, 17:02:06 UTC] {{waiter_with_logging.py:129}} INFO - Status of 
step function execution 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 
   ```
   'states:DescribeExecution'
   ```
   On the StateMachine execution arn.
   ```
   arn:aws:states:<Region>:<accountId>:execution:<stateMachineName>:*
   ```
   
   ### Before granting the permission
   [2024-08-28, 01:41:53 UTC] {{waiter_with_logging.py:129}} INFO - Status of 
step function execution is: 
   ### After Granting the permission
   ```
   [2024-08-28, 17:01:06 UTC] {{waiter_with_logging.py:129}} INFO - Status of 
step function execution is: RUNNING
   ```
   Unfortunately, MWAA does not throw `Accessdenied` permission error if the 
IAM role does not have aforementioned permission on the execution arn of the 
StateMachine. 
   
   
   ### Anything else
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


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