diff --git a/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py b/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py index 86caf83dec..32de3a1d4e 100644 --- a/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py +++ b/taskvine/src/bindings/python3/ndcctools/taskvine/dask_executor.py @@ -260,6 +260,7 @@ def _dask_execute(self, dsk, keys): 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 self.hungry() ): self.submit(enqueued_calls.pop()) submitted += 1