From 04cc910d54ed37232755096ceccd237ac1377c74 Mon Sep 17 00:00:00 2001 From: Igor Ilic Date: Thu, 7 Aug 2025 11:29:17 +0200 Subject: [PATCH] fix: Resolve issue with deadlock during data indexing --- cognee/tasks/storage/index_data_points.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cognee/tasks/storage/index_data_points.py b/cognee/tasks/storage/index_data_points.py index 2b6205f4d..868f1276c 100644 --- a/cognee/tasks/storage/index_data_points.py +++ b/cognee/tasks/storage/index_data_points.py @@ -49,7 +49,8 @@ async def index_data_points(data_points: list[DataPoint]): batch_size = 100 for i in range(0, len(indexable_points), batch_size): batch = indexable_points[i : i + batch_size] - await vector_engine.index_data_points(index_name, field_name, batch) + async with vector_index_lock: + await vector_engine.index_data_points(index_name, field_name, batch) except EmbeddingException as e: logger.warning(f"Failed to index data points for {index_name}.{field_name}: {e}")