#12: fix queue iteration bug (#15)

mixedbread-ai · Dec 17, 2024 · b951bde · b951bde
1 parent 9599bb7
commit b951bde
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/batched/batch_generator.py b/batched/batch_generator.py
@@ -151,7 +151,7 @@ def optimal_batches(self) -> Generator[list[BatchItem[T, U]], None, None]:
 
             n_batches = max(1, queue_size // self._batch_size)
             size_batches = min(self._batch_size * n_batches, queue_size)
-            batch_items = [self._queue._get() for _ in range(size_batches)]  # noqa: SLF001
+            batch_items = [self._queue.get() for _ in range(size_batches)]
             for batch in batch_iter(batch_items, self._batch_size):
                 if self._stop_requested:
                     break

diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "batched"
-version = "0.1.3"
+version = "0.1.4"
 description = "Batched is a flexible and efficient batch processing library implemented in Python. It supports asynchronous batch processing with dynamic batching and prioritization."
 authors = [
     { name = "Mixedbread", email = "support@mixedbread.ai" },