diff --git a/packages/api/src/jobs/sync_read_positions.ts b/packages/api/src/jobs/sync_read_positions.ts index 26ec0b639..756d6429d 100644 --- a/packages/api/src/jobs/sync_read_positions.ts +++ b/packages/api/src/jobs/sync_read_positions.ts @@ -6,8 +6,8 @@ import { fetchCachedReadingPositionsAndMembers, reduceCachedReadingPositionMembers, } from '../services/cached_reading_position' -import { logger } from '../utils/logger' import { updateLibraryItemReadingProgress } from '../services/library_item' +import { logger } from '../utils/logger' export const SYNC_READ_POSITIONS_JOB_NAME = 'sync-read-positions' @@ -86,6 +86,10 @@ export const syncReadPositionsJob = async (_data: any) => { const updates = getSyncUpdatesIterator(redis) for await (const value of updates) { - await syncReadPosition(value) + try { + await syncReadPosition(value) + } catch (error) { + logger.error('error syncing reading position', { error, value }) + } } } diff --git a/packages/api/src/jobs/update_home.ts b/packages/api/src/jobs/update_home.ts index 72e39f3d5..8994fee20 100644 --- a/packages/api/src/jobs/update_home.ts +++ b/packages/api/src/jobs/update_home.ts @@ -438,7 +438,7 @@ const mixHomeItems = ( // use prometheus to monitor the latency of each step const latency = new client.Histogram({ - name: 'update_home_latency', + name: 'omnivore_update_home_latency', help: 'Latency of update home job', labelNames: ['step'], buckets: [0.1, 0.5, 1, 2, 5, 10],