diff --git a/plugins/catalog-backend/src/next/LocationStoreImpl.ts b/plugins/catalog-backend/src/next/LocationStoreImpl.ts index 1b9e9bd92c..f970234f09 100644 --- a/plugins/catalog-backend/src/next/LocationStoreImpl.ts +++ b/plugins/catalog-backend/src/next/LocationStoreImpl.ts @@ -78,7 +78,7 @@ export class LocationStoreImpl implements LocationStore { return this.db.transaction(async tx => { const location = await this.db.location(id); if (!location) { - throw new ConflictError(`No location found with with id: ${id}`); + throw new ConflictError(`No location found with id: ${id}`); } await this.db.removeLocation(tx, id); this.notifyDeletion(location); diff --git a/plugins/catalog-backend/src/next/ProcessingStateManagerImpl.ts b/plugins/catalog-backend/src/next/ProcessingStateManagerImpl.ts index 6cd846d791..522a7a327c 100644 --- a/plugins/catalog-backend/src/next/ProcessingStateManagerImpl.ts +++ b/plugins/catalog-backend/src/next/ProcessingStateManagerImpl.ts @@ -33,7 +33,7 @@ export class ProcessingStateManagerImpl implements ProcessingStateManager { errors: JSON.stringify(result.errors), state: result.state, relations: result.relations, - deferedEntities: result.deferredEntities, + deferredEntities: result.deferredEntities, }); }); } diff --git a/plugins/catalog-backend/src/next/database/ProcessingDatabaseImpl.ts b/plugins/catalog-backend/src/next/database/ProcessingDatabaseImpl.ts index 7c56fcd259..7e9bf78691 100644 --- a/plugins/catalog-backend/src/next/database/ProcessingDatabaseImpl.ts +++ b/plugins/catalog-backend/src/next/database/ProcessingDatabaseImpl.ts @@ -76,7 +76,7 @@ export class ProcessingDatabaseImpl implements ProcessingDatabase { state, errors, relations, - deferedEntities, + deferredEntities, } = options; const refreshResult = await tx('refresh_state') @@ -93,7 +93,7 @@ export class ProcessingDatabaseImpl implements ProcessingDatabase { // Schedule all deferred entities for future processing. await this.addUnprocessedEntities(tx, { - entities: deferedEntities, + entities: deferredEntities, id, type: 'entity', }); @@ -183,7 +183,7 @@ export class ProcessingDatabaseImpl implements ProcessingDatabase { .select() .where('next_update_at', '<=', tx.fn.now()) .limit(request.processBatchSize) - .orderBy('next_update_at', 'desc'); + .orderBy('next_update_at', 'asc'); await tx('refresh_state') .whereIn( diff --git a/plugins/catalog-backend/src/next/database/types.ts b/plugins/catalog-backend/src/next/database/types.ts index d89a3b23bf..22e9e90c8e 100644 --- a/plugins/catalog-backend/src/next/database/types.ts +++ b/plugins/catalog-backend/src/next/database/types.ts @@ -32,7 +32,7 @@ export type UpdateProcessedEntityOptions = { state?: Map; errors?: string; relations: EntityRelationSpec[]; - deferedEntities: Entity[]; + deferredEntities: Entity[]; }; export type RefreshStateItem = {