Fix cluster master to look for queued jobs instead of processing

- Jobs are inserted as 'queued', not 'processing'
- Cluster master now finds and assigns queued jobs
parent acc3a58a
......@@ -1290,7 +1290,7 @@ class ClusterMaster:
from .database import get_db_connection
conn = get_db_connection()
cursor = conn.cursor()
cursor.execute('SELECT * FROM processing_queue WHERE status = ? AND (job_id IS NULL OR job_id = ?)', ('processing', ''))
cursor.execute('SELECT * FROM processing_queue WHERE status = ? AND (job_id IS NULL OR job_id = ?)', ('queued', ''))
jobs = cursor.fetchall()
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