From 13d1133680a241a9423b57d760c2319c20b80670 Mon Sep 17 00:00:00 2001 From: Igor Ilic Date: Fri, 10 Oct 2025 17:14:10 +0200 Subject: [PATCH] chore: Change comments --- cognee/tasks/storage/index_data_points.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cognee/tasks/storage/index_data_points.py b/cognee/tasks/storage/index_data_points.py index ebc4640d6..902789c80 100644 --- a/cognee/tasks/storage/index_data_points.py +++ b/cognee/tasks/storage/index_data_points.py @@ -41,14 +41,14 @@ async def index_data_points(data_points: list[DataPoint]): index_name = index_name_and_field[:first] field_name = index_name_and_field[first + 1 :] - # Split in the usual “range step batch_size” manner + # Create embedding requests per batch to run in parallel later for i in range(0, len(points), batch_size): batch = points[i : i + batch_size] tasks.append( asyncio.create_task(vector_engine.index_data_points(index_name, field_name, batch)) ) - # Fire them all and wait until every task is done. + # Run all embedding requests in parallel await asyncio.gather(*tasks) return data_points