continue with half full pool when DeadLine reached

chexov · Dec 21, 2010 · 6eb8f74 · 6eb8f74
1 parent 6055729
commit 6eb8f74
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/queueit b/queueit
@@ -151,9 +151,11 @@ def qwrapperbatch(tube_in, tube_out, worker_cmd, batch_size=10):
                     LOG.info(u"Timeout reached")
                 batch_jobs.append(job)
             except DeadlineSoon:
-                LOG.debug(u"Oops. Got DeadlineSoon. Touching reserved jobs..")
+                LOG.debug(u"Oops. Got DeadlineSoon. Do not waiting for queue to fill up..")
+                #LOG.debug(u"Oops. Got DeadlineSoon. Touching reserved jobs..")
                 map(lambda j: j.touch(), batch_jobs)
-                continue
+                break
+                #continue
 
         cmd.extend(map(lambda j: j.body, batch_jobs))