Package Products :: Package ZenUtils :: Package celeryintegration :: Module backend :: Class ZODBBackend |
[hide private]
[frames] | no frames]

# Class ZODBBackend

source code

                          object --+
                                   |
    celery.backends.base.BaseBackend --+
                                       |
    celery.backends.base.BaseDictBackend --+
                                           |
                                          ZODBBackend

ZODB result backend for Celery.

Instance Methods | [hide private]
__init__(self, *args, **kwargs) | source code
get_db_options(self) | source code
db(self) Get a handle to the database by whatever means necessary | source code
dmd(self) Use a well-known connection to get a reliable dmd object. | source code
jobmgr(self) | source code
update(self, task_id, **properties) Store properties on a JobRecord. | source code
_store_result(self, task_id, result, status, traceback=None) Store return value and status of an executed task. | source code
_get_task_meta_for(self, task_id) Get task metadata for a task by id. | source code
wait_for(self, task_id, timeout=None, propagate=True, interval=0.5) Check status of a task and return its result when complete. | source code
_forget(self, task_id) Forget about a result. | source code
cleanup(self) Delete expired metadata. | source code
reset(self) | source code
process_cleanup(self) Cleanup actions to do at the end of a task worker process. | source code
Inherited from `celery.backends.base.BaseDictBackend`: `delete_taskset`, `forget`, `get_children`, `get_result`, `get_status`, `get_task_meta`, `get_taskset_meta`, `get_traceback`, `reload_task_result`, `reload_taskset_result`, `restore_taskset`, `save_taskset`, `store_result` Inherited from `celery.backends.base.BaseBackend`: `__reduce__`, `current_task_children`, `decode`, `encode`, `encode_result`, `exception_to_python`, `fallback_chord_unlock`, `mark_as_done`, `mark_as_failure`, `mark_as_retry`, `mark_as_revoked`, `mark_as_started`, `on_chord_apply`, `on_chord_part_return`, `prepare_exception`, `prepare_expires`, `prepare_value`

Class Variables | [hide private]
| CONN_MARKER = `'ZODBBackendConnection'`
| _db = `None`
Inherited from `celery.backends.base.BaseBackend`: `EXCEPTION_STATES`, `READY_STATES`, `TimeoutError`, `UNREADY_STATES`, `subpolling_interval`, `supports_native_join`

Method Details | [hide private]

### __init__(self, *args, **kwargs) (Constructor) | source code
Overrides: celery.backends.base.BaseBackend.__init__

### db(self) | source code
Get a handle to the database by whatever means necessary Decorators: `@property`

### dmd(self) | source code
Use a well-known connection to get a reliable dmd object. Decorators: `@property`

### jobmgr(self) | source code
Decorators: `@property`

### _store_result(self, task_id, result, status, traceback=None) | source code
Store return value and status of an executed task. This runs in a separate thread with a short-lived connection, thereby guaranteeing isolation from the current transaction.

### wait_for(self, task_id, timeout=None, propagate=True, interval=0.5) | source code
Check status of a task and return its result when complete. This runs in a separate thread with a short-lived connection, thereby guaranteeing isolation from the current transaction. Overrides: celery.backends.base.BaseBackend.wait_for

### _forget(self, task_id) | source code
Forget about a result. Overrides: celery.backends.base.BaseDictBackend._forget

### cleanup(self) | source code
Delete expired metadata. Overrides: celery.backends.base.BaseBackend.cleanup

### process_cleanup(self) | source code
Cleanup actions to do at the end of a task worker process. Overrides: celery.backends.base.BaseBackend.process_cleanup (inherited documentation)