diff --git a/apps/worker/src/jobs/events.incoming-event.ts b/apps/worker/src/jobs/events.incoming-event.ts index 1c94f030..dcfd923e 100644 --- a/apps/worker/src/jobs/events.incoming-event.ts +++ b/apps/worker/src/jobs/events.incoming-event.ts @@ -215,6 +215,8 @@ export async function incomingEvent(job: Job) { prevEventJobStatus: await prevEventJob .getState() .catch(() => 'unknown'), + prevEvent, + currEvent: payload, }, `Failed to promote job` ); diff --git a/packages/queue/src/utils.ts b/packages/queue/src/utils.ts index fbdf7c1c..51afd443 100644 --- a/packages/queue/src/utils.ts +++ b/packages/queue/src/utils.ts @@ -5,5 +5,5 @@ export async function findJobByPrefix( matcher: string ) { const delayed = await queue.getJobs('delayed'); - return delayed.find((job) => job.opts.jobId?.startsWith(matcher)); + return delayed.find((job) => job?.opts?.jobId?.startsWith(matcher)); }