addRefreshKEys -> setRefreshKeys
Signed-off-by: Kiss Miklos <miklos@roadie.io>
This commit is contained in:
@@ -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<void> {
|
||||
|
||||
@@ -157,7 +157,7 @@ export interface ProcessingDatabase {
|
||||
*/
|
||||
refresh(txOpaque: Transaction, options: RefreshOptions): Promise<void>;
|
||||
|
||||
addRefreshKeys(
|
||||
setRefreshKeys(
|
||||
txOpaque: Transaction,
|
||||
options: RefreshKeyOptions,
|
||||
): Promise<void>;
|
||||
|
||||
@@ -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,
|
||||
}),
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user