airflow.contrib.sensors.sagemaker_endpoint_sensor

Module Contents

class airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor(endpoint_name, *args, **kwargs)

Bases:airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor

Asks for the state of the endpoint state until it reaches a terminal state. If it fails the sensor errors, the task fails.

Parameters

job_name (str) – job_name of the endpoint instance to check the state of

template_fields = ['endpoint_name']

template_ext = []

non_terminal_states(self)

failed_states(self)

get_sagemaker_response(self)

get_failed_reason_from_response(self, response)

state_from_response(self, response)