Skip to content

Commit b5ba7b5

Browse files
committed
feat: provide original error
1 parent 6402da2 commit b5ba7b5

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed

src/queue_manager.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ class QueueManagerSingleton {
178178
return instance
179179
} catch (error) {
180180
const message = error instanceof Error ? error.message : String(error)
181-
throw new errors.E_ADAPTER_INIT_ERROR([adapter, message])
181+
throw new errors.E_ADAPTER_INIT_ERROR([adapter, message], { cause: error })
182182
}
183183
}
184184

src/schedule_builder.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,12 @@ export class ScheduleBuilder implements PromiseLike<ScheduleResult> {
131131
try {
132132
CronExpressionParser.parse(this.#cronExpression, { tz: this.#timezone })
133133
} catch (error) {
134-
throw new errors.E_INVALID_CRON_EXPRESSION([this.#cronExpression, (error as Error).message])
134+
throw new errors.E_INVALID_CRON_EXPRESSION(
135+
[this.#cronExpression, (error as Error).message],
136+
{
137+
cause: error,
138+
}
139+
)
135140
}
136141
}
137142

src/worker.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ export class Worker {
349349
mergedConfig.maxRetries
350350
)
351351
await this.#adapter.failJob(job.id, queue, e as Error, retention.removeOnFail)
352-
const exception = new errors.E_JOB_MAX_ATTEMPTS_REACHED([job.name])
352+
const exception = new errors.E_JOB_MAX_ATTEMPTS_REACHED([job.name], { cause: e })
353353
await instance.failed?.(exception)
354354

355355
return

0 commit comments

Comments
 (0)