Fix cluster master to look for processing jobs

- Queue manager marks jobs as processing, cluster master assigns them
- Changed query back to look for processing jobs without job_id
parent 668c482a
...@@ -1292,7 +1292,7 @@ class ClusterMaster: ...@@ -1292,7 +1292,7 @@ class ClusterMaster:
from .database import get_db_connection from .database import get_db_connection
conn = get_db_connection() conn = get_db_connection()
cursor = conn.cursor() cursor = conn.cursor()
cursor.execute('SELECT * FROM processing_queue WHERE status = ? AND (job_id IS NULL OR job_id = ?)', ('queued', '')) cursor.execute('SELECT * FROM processing_queue WHERE status = ? AND (job_id IS NULL OR job_id = ?)', ('processing', ''))
jobs = cursor.fetchall() jobs = cursor.fetchall()
conn.close() conn.close()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment