From ae1db8fb03cc212e6f00f203bd974270fecdd989 Mon Sep 17 00:00:00 2001
From: Mike Bonnet <mikeb@redhat.com>
Date: Jun 13 2014 15:23:38 +0000
Subject: use SELECT ... FOR UPDATE in taskWaitCheck() because those rows may be updated in taskWait()


---

diff --git a/hub/kojihub.py b/hub/kojihub.py
index 6e4c280..e75c2e9 100644
--- a/hub/kojihub.py
+++ b/hub/kojihub.py
@@ -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']