// ExecutionGraph nodes move from `pending_submission` to `in_flight` to `satisfied_promises`.
pending_submission = {}
in_flight = {}
satisfied_promises = set()
def submit_satisfied_pending():
for promise, plan in pending_submission.items():
if plan.promises.issubset(satisfied_promises):
After Change
executor = self.Executor(self._pool, self._pool_size, fail_slow=fail_slow, debug=self._debug)
// Steps move from `pending_submission` to `in_flight`.
pending_submission = OrderedSet()
in_flight = dict()
def submit_until(n):
Submit pending while there"s capacity, and more than `n` items pending_submission.
