gmakstutis/cognee
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: Change comments

Browse source
This commit is contained in:
Igor Ilic 2025-10-10 17:14:10 +02:00
parent 757d745b5d
commit 13d1133680
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
cognee/tasks/storage/index_data_points.py
View file

@ -41,14 +41,14 @@ async def index_data_points(data_points: list[DataPoint]):
index_name = index_name_and_field[:first] index_name = index_name_and_field[:first]
field_name = index_name_and_field[first + 1 :] 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): for i in range(0, len(points), batch_size):
batch = points[i : i + batch_size] batch = points[i : i + batch_size]
tasks.append( tasks.append(
asyncio.create_task(vector_engine.index_data_points(index_name, field_name, batch)) 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) await asyncio.gather(*tasks)
return data_points return data_points