Skip to content

Commit 1661672

Browse files
Fix optional covariates check in incremental indexing (#1374)
* Fix optional covariates check in incremental indexing * Oopsie fix
1 parent a8ccded commit 1661672

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
{
2+
"type": "patch",
3+
"description": "Fix optional covariates update in incremental indexing"
4+
}

graphrag/index/update/incremental_index.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,8 +120,12 @@ async def update_dataframe_outputs(
120120
)
121121

122122
# Merge final covariates
123-
progress_reporter.info("Updating Final Covariates")
124-
await _update_covariates(dataframe_dict, storage, update_storage)
123+
if (
124+
await storage.has("create_final_covariates.parquet")
125+
and "create_final_covariates" in dataframe_dict
126+
):
127+
progress_reporter.info("Updating Final Covariates")
128+
await _update_covariates(dataframe_dict, storage, update_storage)
125129

126130
# Merge final nodes and update community ids
127131
progress_reporter.info("Updating Final Nodes")

0 commit comments

Comments
 (0)