We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9f8a7e0 commit e748945Copy full SHA for e748945
server/src/services/job.service.ts
@@ -186,11 +186,16 @@ export class JobService {
186
this.jobRepository.addHandler(queueName, concurrency, async (item: JobItem): Promise<void> => {
187
const { name, data } = item;
188
189
+ const handler = jobHandlers[name];
190
+ if (!handler) {
191
+ this.logger.warn(`Skipping unknown job: "${name}"`);
192
+ return;
193
+ }
194
+
195
const queueMetric = `immich.queues.${snakeCase(queueName)}.active`;
196
this.metricRepository.jobs.addToGauge(queueMetric, 1);
197
198
try {
- const handler = jobHandlers[name];
199
const status = await handler(data);
200
const jobMetric = `immich.jobs.${name.replaceAll('-', '_')}.${status}`;
201
this.metricRepository.jobs.addToCounter(jobMetric, 1);
0 commit comments