Fix optional covariates check in incremental indexing (#1374)

* Fix optional covariates check in incremental indexing

* Oopsie fix
This commit is contained in:
Alonso Guevara 2024-11-06 17:22:11 -06:00 committed by GitHub
parent a8ccded83c
commit 1661672569
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 10 additions and 2 deletions

View File

@ -0,0 +1,4 @@
{
"type": "patch",
"description": "Fix optional covariates update in incremental indexing"
}

View File

@ -120,8 +120,12 @@ async def update_dataframe_outputs(
)
# Merge final covariates
progress_reporter.info("Updating Final Covariates")
await _update_covariates(dataframe_dict, storage, update_storage)
if (
await storage.has("create_final_covariates.parquet")
and "create_final_covariates" in dataframe_dict
):
progress_reporter.info("Updating Final Covariates")
await _update_covariates(dataframe_dict, storage, update_storage)
# Merge final nodes and update community ids
progress_reporter.info("Updating Final Nodes")