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

fix: Resolve issue with data element incremental loading for multiple datasets

Browse source
This commit is contained in:
Igor Ilic 2025-10-15 18:26:01 +02:00
parent c73e8964a1
commit c9a3f48398
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
cognee/modules/pipelines/operations/run_tasks_data_item.py
View file

@ -115,9 +115,8 @@ async def run_tasks_data_item_incremental(
data_point = ( data_point = (
await session.execute(select(Data).filter(Data.id == data_id)) await session.execute(select(Data).filter(Data.id == data_id))
).scalar_one_or_none() ).scalar_one_or_none()
data_point.pipeline_status[pipeline_name] = { status_for_pipeline = data_point.pipeline_status.setdefault(pipeline_name, {})
str(dataset.id): DataItemStatus.DATA_ITEM_PROCESSING_COMPLETED status_for_pipeline[str(dataset.id)] = DataItemStatus.DATA_ITEM_PROCESSING_COMPLETED
}
await session.merge(data_point) await session.merge(data_point)
await session.commit() await session.commit()