Add logging when jobs are waiting for workers

parent 109e1dc9
......@@ -137,6 +137,8 @@ class QueueManager:
job = pending[0] # Get highest priority job
if self._can_start_job(job):
self._start_job(job)
else:
print(f"Job {job['id']} waiting for available workers")
time.sleep(1) # Check every second
except Exception as e:
......
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