Package Products :: Package ZenUtils :: Package celeryintegration :: Module backend :: Class ZODBBackend

Class ZODBBackend

                      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