diff --git a/package.json b/package.json index 9002c8dd4e739..6cbaac3044104 100644 --- a/package.json +++ b/package.json @@ -90,6 +90,7 @@ "ws": ">=8.17.1" }, "patchedDependencies": { + "bull@4.12.1": "patches/bull@4.12.1.patch", "pkce-challenge@3.0.0": "patches/pkce-challenge@3.0.0.patch", "pyodide@0.23.4": "patches/pyodide@0.23.4.patch", "@types/express-serve-static-core@4.17.43": "patches/@types__express-serve-static-core@4.17.43.patch", diff --git a/patches/bull@4.12.1.patch b/patches/bull@4.12.1.patch new file mode 100644 index 0000000000000..2c68a3386505a --- /dev/null +++ b/patches/bull@4.12.1.patch @@ -0,0 +1,21 @@ +diff --git a/lib/job.js b/lib/job.js +index 6a3606974fd3e397c6c5b2b6e65b20670c68f753..4cdbed1d564ceeb5a80c92eb605e49cfd3c8ccdd 100644 +--- a/lib/job.js ++++ b/lib/job.js +@@ -511,9 +511,14 @@ Job.prototype.finished = async function() { + } + }; + +- const onFailed = (jobId, failedReason) => { ++ const onFailed = async (jobId, failedReason) => { + if (String(jobId) === String(this.id)) { +- reject(new Error(failedReason)); ++ const job = await Job.fromId(this.queue, this.id); ++ const error = new Error(failedReason); ++ if (job && job.stacktrace && job.stacktrace.length > 0) { ++ error.stack = job.stacktrace.join('\n'); ++ } ++ reject(error); + removeListeners(); + } + }; diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index 679b1155d2297..3b8af7dd40aa5 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -130,6 +130,9 @@ patchedDependencies: '@types/ws@8.5.4': hash: nbzuqaoyqbrfwipijj5qriqqju path: patches/@types__ws@8.5.4.patch + bull@4.12.1: + hash: ep6h4rqtpclldfcdohxlgcb3aq + path: patches/bull@4.12.1.patch pkce-challenge@3.0.0: hash: dypouzb3lve7vncq25i5fuanki path: patches/pkce-challenge@3.0.0.patch @@ -822,7 +825,7 @@ importers: version: 2.4.3 bull: specifier: 4.12.1 - version: 4.12.1 + version: 4.12.1(patch_hash=ep6h4rqtpclldfcdohxlgcb3aq) cache-manager: specifier: 5.2.3 version: 5.2.3 @@ -19827,7 +19830,7 @@ snapshots: - supports-color optional: true - bull@4.12.1: + bull@4.12.1(patch_hash=ep6h4rqtpclldfcdohxlgcb3aq): dependencies: cron-parser: 4.9.0 get-port: 5.1.1