Function commit_batch

scripts/bwb_opds_imports.py:362–366

(batch_name: str, olbooks: list[dict[str, Any]], batch_size: int = 1000)

def commit_batch(batch_name: str, olbooks: list[dict[str, Any]], batch_size: int = 1000) -> None:
    batch = Batch.find(batch_name) or Batch.new(batch_name)
    items = [{"ia_id": b["source_records"][0], "data": b} for b in olbooks]
    for i in range(0, len(items), batch_size):
        batch.add_items(items[i : i + batch_size])


def main(