selinonlib.storages.sql_storage module¶

Selinon SQL Database adapter - PostgreSQL.

class selinonlib.storages.sql_storage.Result(node_args, flow_name, task_name, task_id, result)[source]¶

Bases: sqlalchemy.ext.declarative.api.Base

Record for a task result.

flow_name¶

id¶

node_args¶

result¶

task_id¶

task_name¶

class selinonlib.storages.sql_storage.SqlStorage(connection_string, encoding='utf-8', echo=False)[source]¶

Bases: selinon.dataStorage.DataStorage

Selinon SQL Database adapter - PostgreSQL.

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]¶