airflow.contrib.sensors.redis_key_sensor

Module Contents

class airflow.contrib.sensors.redis_key_sensor.RedisKeySensor(key, redis_conn_id, *args, **kwargs)[source]

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Checks for the existence of a key in a Redis

template_fields = ['key'][source]
ui_color = #f0eee4[source]
poke(self, context)[source]

Was this entry helpful?