Skip to content

Commit 5b41ba4

Browse files
committed
fix: Adds missing rejection reason to EnqueueError
1 parent 80bce8a commit 5b41ba4

2 files changed

Lines changed: 4 additions & 0 deletions

File tree

src/error.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ export class DocMQError extends Error {
2020
export class EnqueueError extends DocMQError {
2121
type = "EnqueueError";
2222
jobs: unknown[] = [];
23+
errors: unknown[] = [];
2324
}
2425

2526
/**

src/queue.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,10 +254,12 @@ export class Queue<T, A = unknown, F extends Error = Error> {
254254
// split into success/failure
255255
const success: JobDefinition<T>[] = [];
256256
const failure: JobDefinition<T>[] = [];
257+
const errors: unknown[] = [];
257258
results.forEach((r, idx) => {
258259
const j = bulkJobs[idx];
259260
if (r.status === "rejected") {
260261
failure.push(j);
262+
errors.push(r.reason);
261263
} else {
262264
success.push(j);
263265
}
@@ -272,6 +274,7 @@ export class Queue<T, A = unknown, F extends Error = Error> {
272274
"Unable to add the included jobs to the queue"
273275
);
274276
err.jobs = failure;
277+
err.errors = errors;
275278
this.events.emit("error", err);
276279
}
277280
}

0 commit comments

Comments
 (0)