diff --git a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts index 472c79e516..c57b5977a7 100644 --- a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts @@ -566,7 +566,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { const { entityRef } = options; const updateResult = await tx('refresh_state') - .where({ entity_ref: entityRef }) + .where({ entity_ref: entityRef.toLocaleLowerCase('en-US') }) .update({ next_update_at: tx.fn.now() }); if (updateResult === 0) { throw new ConflictError(`Failed to schedule ${entityRef} for refresh`);