_abatch() — langchain Function Reference

Architecture documentation for the _abatch() function in api.py from the langchain codebase.

Function python CoreAbstractions Serialization called by 1

Entity Profile

CoreAbstractions→ Serialization→ _abatch() — langchain Function Reference

Dependency Diagram

graph TD
  edbcc417_69c7_d8bc_0a8b_194cd8c3dd73["_abatch()"]
  203188c0_72d6_6932_bc21_edf25c4c00ef["api.py"]
  edbcc417_69c7_d8bc_0a8b_194cd8c3dd73 -->|defined in| 203188c0_72d6_6932_bc21_edf25c4c00ef
  02b67c59_d093_f33d_633c_d77332eb191e["aindex()"]
  02b67c59_d093_f33d_633c_d77332eb191e -->|calls| edbcc417_69c7_d8bc_0a8b_194cd8c3dd73
  style edbcc417_69c7_d8bc_0a8b_194cd8c3dd73 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/indexing/api.py lines 101–113

async def _abatch(size: int, iterable: AsyncIterable[T]) -> AsyncIterator[list[T]]:
    """Utility batching function."""
    batch: list[T] = []
    async for element in iterable:
        if len(batch) < size:
            batch.append(element)

        if len(batch) >= size:
            yield batch
            batch = []

    if batch:
        yield batch