diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts index f0779212be..903dd59e9e 100644 --- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts @@ -542,7 +542,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { const tx = txOpaque as Knex.Transaction; const { keys } = options; - const updateResult = await tx('refresh_state') + await tx('refresh_state') .whereIn('entity_id', function selectEntityRefs(tx2) { tx2 .whereIn('key', keys) @@ -552,12 +552,6 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { .from('refresh_keys'); }) .update({ next_update_at: tx.fn.now() }); - - if (updateResult === 0) { - this.options.logger.info( - `Failed to schedule ${JSON.stringify(keys)} for keys`, - ); - } } async transaction(fn: (tx: Transaction) => Promise): Promise {