Signed-off-by: Petr Pudlak <[email protected]>
---
src/Ganeti/JQScheduler.hs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/Ganeti/JQScheduler.hs b/src/Ganeti/JQScheduler.hs
index 12f6fa5..140ce11 100644
--- a/src/Ganeti/JQScheduler.hs
+++ b/src/Ganeti/JQScheduler.hs
@@ -278,7 +278,7 @@ jobEligible queue jWS =
-- pure function doing the scheduling.
selectJobsToRun :: Int -> Queue -> (Queue, [JobWithStat])
selectJobsToRun count queue =
- let n = count - length (qRunning queue)
+ let n = count - length (qRunning queue) - length (qManipulated queue)
chosen = take n . filter (jobEligible queue) $ qEnqueued queue
remain = deleteFirstsBy ((==) `on` (qjId . jJob)) (qEnqueued queue)
chosen
in (queue {qEnqueued=remain, qRunning=qRunning queue ++ chosen}, chosen)
--
1.9.1.423.g4596e3a
