backends.database

SQLAlchemy result store backend.

Package Contents

Classes

DatabaseBackend(self,dburi=None,engine_options=None,url=None,**kwargs) The database result backend.

Functions

session_cleanup(session)
retry(fun)
session_cleanup(session)
retry(fun)
class DatabaseBackend(dburi=None, engine_options=None, url=None, **kwargs)

The database result backend.

__init__(dburi=None, engine_options=None, url=None, **kwargs)
ResultSession(session_manager=SessionManager)
_store_result(task_id, result, state, traceback=None, max_retries=3, **kwargs)

Store return value and state of an executed task.

_get_task_meta_for(task_id)

Get task meta-data for a task by id.

_save_group(group_id, result)

Store the result of an executed group.

_restore_group(group_id)

Get meta-data for group by id.

_delete_group(group_id)

Delete meta-data for group by id.

_forget(task_id)

Forget about result.

cleanup()

Delete expired meta-data.

__reduce__(args=tuple, kwargs=dict)