code: def _push_next(self):
          
          r = next(self._iter, None)
          if r is None:
              return
          self._key_queue.put((self._sent_idx, r))
          self._sent_idx += 1
docs: Assign next batch workload to workers.