tbelway/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2025-05-31 04:06:26 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(server): gracefully handle unknown jobs (#12870)

Browse Source
This commit is contained in:
Jason Rasmussen 2024-09-23 13:22:36 -04:00 committed by GitHub
parent 9f8a7e0bea
commit e748945b4f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/src/services/job.service.ts
View File

@ -186,11 +186,16 @@ export class JobService {
this.jobRepository.addHandler(queueName, concurrency, async (item: JobItem): Promise<void> => { this.jobRepository.addHandler(queueName, concurrency, async (item: JobItem): Promise<void> => {
const { name, data } = item; const { name, data } = item;
const handler = jobHandlers[name];
if (!handler) {
this.logger.warn(`Skipping unknown job: "${name}"`);
return;
}
const queueMetric = `immich.queues.${snakeCase(queueName)}.active`; const queueMetric = `immich.queues.${snakeCase(queueName)}.active`;
this.metricRepository.jobs.addToGauge(queueMetric, 1); this.metricRepository.jobs.addToGauge(queueMetric, 1);
try { try {
const handler = jobHandlers[name];
const status = await handler(data); const status = await handler(data);
const jobMetric = `immich.jobs.${name.replaceAll('-', '_')}.${status}`; const jobMetric = `immich.jobs.${name.replaceAll('-', '_')}.${status}`;
this.metricRepository.jobs.addToCounter(jobMetric, 1); this.metricRepository.jobs.addToCounter(jobMetric, 1);