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?