zodb Package

db Module

opennode.oms.zodb.db.get_db()

opennode.oms.zodb.db.get_connection(accept_main_thread=False)

opennode.oms.zodb.db.get_root(accept_main_thread=False)

opennode.oms.zodb.db.transact(fun)

Runs a callable inside a separate thread within a ZODB transaction.

Returned values are deeply copied. Currently only zodb objects returned directly or contained in the first level content of lists/sets/dicts are copied.

opennode.oms.zodb.db.ref(obj)

opennode.oms.zodb.db.deref(obj_id)

extractors Module

opennode.oms.zodb.extractors.context_from_method(fun, args, kwargs)

Currently works only for methods by assuming that the first argument is self. Unfortunately we cannot know the dynamic binding for the method because the @transact decorator is invoked at class definition time.

If self is already a persistent object with a context attached, then that context is returned, otherwise it searches for matching IContextExtractor subscription adpaters.

packer Module

class opennode.oms.zodb.packer.PackDaemonProcess

Bases: opennode.oms.model.model.proc.DaemonProcess

pack(*args, **kwargs)

run(*args, **kwargs)

proxy Module

class opennode.oms.zodb.proxy.PersistentProxy(obj, context)

Bases: object

This is a proxy object which tracks attribute acces when the persistent object is outsite a living transaction (e.g. when returned from a db.transact deferred). The access will cause an exception if it’s done in the main thread. Access done in a zodb thread will cause the object to be reloaded in the current transaction.

opennode.oms.zodb.proxy.make_persistent_proxy(res, context={})