Amazon
Amazon »

EmrStepSensor

View on GitHub

Created by

Airflow Community

Last Updated

Version

7.3.0

Asks for the state of the step until it reaches any of the target states.

Parameters

job_flow_id

strREQUIRED

job_flow_id which contains the step check the state of

step_id

strREQUIRED

step to check the state of

target_states

Iterable[str] | None

the target states, sensor waits until step reaches any of these states

failed_states

Iterable[str] | None

the failure states, sensor fails when step reaches any of these states

Documentation

Asks for the state of the step until it reaches any of the target states. If it fails the sensor errors, failing the task.

With the default target states, sensor waits step to be completed.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon EMR step state