Fixed typo errors in db api

This commit is contained in:
tengqm
2015-02-04 20:26:23 +08:00
parent 2f1b651894
commit b7b3aed3d0
2 changed files with 2 additions and 2 deletions

View File

@@ -139,7 +139,7 @@ def cluster_lock_release(cluster_id, action_id, scope):
def cluster_lock_steal(node_id, action_id):
return IMPL.cluster_lock_steal(node_id, new_action_id)
return IMPL.cluster_lock_steal(node_id, action_id)
def node_lock_acquire(node_id, action_id):

View File

@@ -450,7 +450,7 @@ def cluster_lock_release(cluster_id, action_id, scope):
def cluster_lock_steal(cluster_id, action_id):
session = get_session()
session.begin():
session.begin()
lock = session.query(models.ClusterLock).get(cluster_id)
if lock is not None:
lock.action_ids = [action_id]