`airflow.contrib.sensors.emr_base_sensor`¶

Module Contents¶

class airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor(aws_conn_id='aws_default', *args, **kwargs)[source]¶

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Contains general sensor behavior for EMR. Subclasses should implement get_emr_response() and state_from_response() methods. Subclasses should also implement NON_TERMINAL_STATES and FAILED_STATE constants.

ui_color = #66c3ff[source]¶

poke(self, context)[source]¶

Was this entry helpful?