Skip to content

Commit d8e1e48

Browse files
committed
normalize ID logging
1 parent f62cd89 commit d8e1e48

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

packages/backend/src/queue/QueueProcessorService.ts

+4-4
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
186186
.on('active', (job) => logger.debug(`active id=${job.id}`))
187187
.on('completed', (job, result) => logger.debug(`completed(${result}) id=${job.id}`))
188188
.on('failed', (job, err: Error) => {
189-
logger.error(`failed(${err.name}: ${err.message}) id=${job ? job.id : '-'}`, { job: renderJob(job), e: renderError(err) });
189+
logger.error(`failed(${err.name}: ${err.message}) id=${job?.id ?? '?'}`, { job: renderJob(job), e: renderError(err) });
190190
if (config.sentryForBackend) {
191191
Sentry.captureMessage(`Queue: System: ${job?.name ?? '?'}: ${err.name}: ${err.message}`, {
192192
level: 'error',
@@ -251,7 +251,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
251251
.on('active', (job) => logger.debug(`active id=${job.id}`))
252252
.on('completed', (job, result) => logger.debug(`completed(${result}) id=${job.id}`))
253253
.on('failed', (job, err) => {
254-
logger.error(`failed(${err.name}: ${err.message}) id=${job ? job.id : '-'}`, { job: renderJob(job), e: renderError(err) });
254+
logger.error(`failed(${err.name}: ${err.message}) id=${job?.id ?? '?'}`, { job: renderJob(job), e: renderError(err) });
255255
if (config.sentryForBackend) {
256256
Sentry.captureMessage(`Queue: DB: ${job?.name ?? '?'}: ${err.name}: ${err.message}`, {
257257
level: 'error',
@@ -458,7 +458,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
458458
.on('active', (job) => logger.debug(`active id=${job.id}`))
459459
.on('completed', (job, result) => logger.debug(`completed(${result}) id=${job.id}`))
460460
.on('failed', (job, err) => {
461-
logger.error(`failed(${err.name}: ${err.message}) id=${job ? job.id : '-'}`, { job: renderJob(job), e: renderError(err) });
461+
logger.error(`failed(${err.name}: ${err.message}) id=${job?.id ?? '?'}`, { job: renderJob(job), e: renderError(err) });
462462
if (config.sentryForBackend) {
463463
Sentry.captureMessage(`Queue: Relationship: ${job?.name ?? '?'}: ${err.name}: ${err.message}`, {
464464
level: 'error',
@@ -499,7 +499,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
499499
.on('active', (job) => logger.debug(`active id=${job.id}`))
500500
.on('completed', (job, result) => logger.debug(`completed(${result}) id=${job.id}`))
501501
.on('failed', (job, err) => {
502-
logger.error(`failed(${err.name}: ${err.message}) id=${job ? job.id : '-'}`, { job: renderJob(job), e: renderError(err) });
502+
logger.error(`failed(${err.name}: ${err.message}) id=${job?.id ?? '?'}`, { job: renderJob(job), e: renderError(err) });
503503
if (config.sentryForBackend) {
504504
Sentry.captureMessage(`Queue: ObjectStorage: ${job?.name ?? '?'}: ${err.name}: ${err.message}`, {
505505
level: 'error',

0 commit comments

Comments
 (0)