diff --git a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts index ead857576c..faf7197bc5 100644 --- a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts @@ -471,7 +471,6 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { .limit(request.processBatchSize) .orderBy('next_update_at', 'asc'); - const nextRefresh = Math.random() * (150 - 100) + 100; await tx('refresh_state') .whereIn( 'entity_ref', @@ -480,8 +479,14 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { .update({ next_update_at: tx.client.config.client === 'sqlite3' - ? tx.raw(`datetime('now', ?)`, [`${nextRefresh} seconds`]) - : tx.raw(`now() + interval '${Number(nextRefresh)} seconds'`), + ? tx.raw(`datetime('now', ?)`, [ + `${this.options.refreshIntervalSeconds} seconds`, + ]) + : tx.raw( + `now() + interval '${Number( + this.options.refreshIntervalSeconds, + )} seconds'`, + ), }); return {