private_transaction = False
# Find the session object
- try:
- session = kwargs['session']
- except KeyError:
+ session = kwargs.get('session')
+
+ if session is None:
if len(args) <= len(getargspec(fn)[0]) - 1:
# No session specified as last argument or in kwargs
private_transaction = True
else:
# Session is last argument in args
session = args[-1]
+ if session is None:
+ args = list(args)
+ session = args[-1] = DBConn().session()
+ private_transaction = True
if private_transaction:
session.commit_or_flush = session.commit