`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

job_flow_id (str) – job_flow_id which contains the step check the state of
step_id (str) – step to check the state of

NON_TERMINAL_STATES = ['PENDING', 'RUNNING', 'CONTINUE', 'CANCEL_PENDING'][source]¶

FAILED_STATE = ['CANCELLED', 'FAILED', 'INTERRUPTED'][source]¶

template_fields = ['job_flow_id', 'step_id'][source]¶

template_ext = [][source]¶

get_emr_response(self)[source]¶

static state_from_response(response)[source]¶

static failure_message_from_response(response)[source]¶

Was this entry helpful?