vine: hungry submit

cooperative-computing-lab · Nov 25, 2024 · 0023faa · 0023faa
1 parent 8530039
commit 0023faa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py b/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py
@@ -259,7 +259,8 @@ def _dask_execute(self, dsk, keys):
                 while (
                     enqueued_calls
                     and (not self.submit_per_cycle or submitted < self.submit_per_cycle)
-                    and (not self.max_pending or pending < self.max_pending)
+                    and (not self.max_pending or pending < self.max_pending
+                    and self.hungry())
                 ):
                     self.submit(enqueued_calls.pop())
                     submitted += 1