selinonlib.storages.redis module¶

Selinon adapter for Redis database.

class selinonlib.storages.redis.RedisStorage(host='localhost', port=6379, db=0, password=None, socket_timeout=None, connection_pool=None, charset='utf-8', errors='strict', unix_socket_path=None)[source]¶

Bases: selinon.dataStorage.DataStorage

Selinon adapter for Redis database.

connect()[source]¶

disconnect()[source]¶

is_connected()[source]¶

retrieve(flow_name, task_name, task_id)[source]¶

store(node_args, flow_name, task_name, task_id, result)[source]¶

store_error(node_args, flow_name, task_name, task_id, exc_info)[source]¶