airflow.contrib.sensors.emr_step_sensor
¶
Module Contents¶
-
class
airflow.contrib.sensors.emr_step_sensor.
EmrStepSensor
(job_flow_id, step_id, *args, **kwargs)[source]¶ Bases:
airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor
Asks for the state of the step until it reaches a terminal state. If it fails the sensor errors, failing the task.
- Parameters