max_jobs <=0 indicates an error, for now

PacificBiosciences · Aug 2, 2018 · 6c7d284 · 6c7d284
1 parent ecbed43
commit 6c7d284
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pypeflow/simple_pwatcher_bridge.py b/pypeflow/simple_pwatcher_bridge.py
@@ -305,6 +305,9 @@ def _refreshTargets(self, updateFreq, exitOnFailure):
         while ready or submitted:
             # Nodes cannot be in ready or submitted unless they are also in unsatg.
             to_submit = set()
+            if self.max_jobs <= 0:
+                msg = 'self.max_jobs={}'.format(self.max_jobs)
+                raise Exception(msg)
             while ready and (self.max_jobs > len(submitted) + len(to_submit)):
                 node = ready.pop()
                 to_submit.add(node)