Wake a cfbot worker when work_queue retry is overdue.

This was already happening anyway due to regular wakeup traffic but
it's better to have an explicit check every minute just to crank the
handle a bit sooner.

Author: macdice

cfbot_periodic_minutely.py

@@ -7,6 +7,7 @@
 import cfbot_patch
 import cfbot_util
 import cfbot_web
+import cfbot_work_queue
 
 import errno
 import fcntl
@@ -29,6 +30,8 @@ def try_lock():
 
 def run():
     with cfbot_util.db() as conn:
+        cfbot_work_queue.maybe_trigger_retries(conn)
+
         # get the current Commitfest ID
         cfs = cfbot_commitfest_rpc.get_current_commitfests()
 

cfbot_work_queue.py

@@ -54,6 +54,20 @@ def insert_work_queue_if_not_exists(cursor, type, key=None):
         insert_work_queue(cursor, type, key)
 
 
+def maybe_trigger_retries(conn):
+    # This is called by cfbot_periodic_minutely.py to see if we should wake up
+    # a worker to handle retries.  Not strictly necessary since there is
+    # regular traffic anyway, but...
+    cursor = conn.cursor()
+    cursor.execute("""select 1
+                        from work_queue
+                       where status = 'WORK' and lease < now()
+                       limit 1""")
+    if cursor.fetchone():
+        cursor.execute("notify work_queue")
+        conn.commit()
+
+
 def process_one_job(conn, fetch_only):
     cursor = conn.cursor()
     if fetch_only: