fix(server): gracefully handle unknown jobs (immich-app#12870)

cxmlg · Sep 23, 2024 · e748945 · e748945
1 parent 9f8a7e0
commit e748945
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/server/src/services/job.service.ts b/server/src/services/job.service.ts
@@ -186,11 +186,16 @@ export class JobService {
       this.jobRepository.addHandler(queueName, concurrency, async (item: JobItem): Promise<void> => {
         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`;
         this.metricRepository.jobs.addToGauge(queueMetric, 1);
 
         try {
-          const handler = jobHandlers[name];
           const status = await handler(data);
           const jobMetric = `immich.jobs.${name.replaceAll('-', '_')}.${status}`;
           this.metricRepository.jobs.addToCounter(jobMetric, 1);