particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

use SELECT ... FOR UPDATE in taskWaitCheck() because those rows may be updated in taskWait()

Browse source
This commit is contained in:
Mike Bonnet 2014-05-27 15:19:50 -04:00 • committed by Mike McLean
parent af29196d0f
commit ae1db8fb03
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
hub/kojihub.py
View file

@ -9500,7 +9500,8 @@ class Host(object):
c = context.cnx.cursor()
q = """
SELECT id,state FROM task
WHERE parent=%(parent)s AND awaited = TRUE"""
WHERE parent=%(parent)s AND awaited = TRUE
FOR UPDATE"""
c.execute(q,locals())
canceled = koji.TASK_STATES['CANCELED']
closed = koji.TASK_STATES['CLOSED']