diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts index e4a5ab3d85..20ef39f6e8 100644 --- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts @@ -533,7 +533,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { await Promise.all(rows.map(r => this.refresh(tx, r.entity_ref))); } - async addRefreshKeys( + async setRefreshKeys( txOpaque: Transaction, options: RefreshKeyOptions, ): Promise { diff --git a/plugins/catalog-backend/src/database/types.ts b/plugins/catalog-backend/src/database/types.ts index bf3f765f4a..9d4043a340 100644 --- a/plugins/catalog-backend/src/database/types.ts +++ b/plugins/catalog-backend/src/database/types.ts @@ -157,7 +157,7 @@ export interface ProcessingDatabase { */ refresh(txOpaque: Transaction, options: RefreshOptions): Promise; - addRefreshKeys( + setRefreshKeys( txOpaque: Transaction, options: RefreshKeyOptions, ): Promise; diff --git a/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts b/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts index d3d679d2b7..5cb9c76e62 100644 --- a/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts +++ b/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts @@ -124,7 +124,7 @@ export class DefaultCatalogProcessingEngine implements CatalogProcessingEngine { let hashBuilder = this.createHash().update(errorsString); if (result.ok) { await this.processingDatabase.transaction(tx => - this.processingDatabase.addRefreshKeys(tx, { + this.processingDatabase.setRefreshKeys(tx, { keys: result.refreshKeys, }), );