airflow.providers.redis.sensors.redis_key¶

Classes¶

RedisKeySensor

Checks for the existence of a key in a Redis.

Module Contents¶

class airflow.providers.redis.sensors.redis_key.RedisKeySensor(*, key, redis_conn_id, **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseSensorOperator

Checks for the existence of a key in a Redis.

Parameters:: redis_conn_id (str) – the redis connection id (templated)

template_fields: collections.abc.Sequence[str] = ('key', 'redis_conn_id')[source]¶

ui_color = '#f0eee4'[source]¶

redis_conn_id[source]¶

key[source]¶

poke(context)[source]¶

Override when deriving this class.

Was this entry helpful?