X-Git-Url: http://xvm.mit.edu/gitweb/invirt/packages/invirt-web.git/blobdiff_plain/a68b7d4c62a3d9025d4f3e3675fe8360b0a827fb..dc5962060920e5b064064f10e539d49a68c9da68:/code/cache_acls.py diff --git a/code/cache_acls.py b/code/cache_acls.py index 2b3fd6c..414f2e3 100644 --- a/code/cache_acls.py +++ b/code/cache_acls.py @@ -45,26 +45,26 @@ def refreshMachine(m): old_people = set(a.user for a in m.acl) for removed in old_people - people: ma = [x for x in m.acl if x.user == removed][0] - ctx.current.delete(ma) + session.delete(ma) for p in people - old_people: ma = MachineAccess(user=p) m.acl.append(ma) - ctx.current.save(ma) + session.save_or_update(ma) def refreshCache(): - transaction = ctx.current.create_transaction() + session.begin() try: machines = Machine.select() for m in machines: refreshMachine(m) - ctx.current.flush() + session.flush() # Atomically execute our changes - transaction.commit() + session.commit() except: # Failed! Rollback all the changes. - transaction.rollback() + session.rollback() raise if __name__ == '__main__':