airflow.contrib.sensors.emr_job_flow_sensor
¶
Module Contents¶
-
class
airflow.contrib.sensors.emr_job_flow_sensor.
EmrJobFlowSensor
(job_flow_id, *args, **kwargs)[source]¶ Bases:
airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor
Asks for the state of the JobFlow until it reaches a terminal state. If it fails the sensor errors, failing the task.
- Parameters
job_flow_id (str) – job_flow_id to check the state of