StepFunctionExecutionSensor
AmazonAsks for the state of the AWS Step Function State Machine Execution until it reaches a failure state or success state. If it fails, then fail the task.
Access Instructions
Install the Amazon provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
execution_arnRequiredexecution_arn to check the state of
aws_conn_idaws connection to use, defaults to ‘aws_default’
Documentation
Asks for the state of the AWS Step Function State Machine Execution until it reaches a failure state or success state. If it fails, then fail the task.
On successful completion of the Execution the Sensor will do an XCom Push of the State Machine’s output to output
See also
For more information on how to use this sensor, take a look at the guide: Wait on an AWS Step Functions state machine execution state