diff --git a/src/common/worker.ts b/src/common/worker.ts index f14ea3bb..55e55cd8 100644 --- a/src/common/worker.ts +++ b/src/common/worker.ts @@ -5,6 +5,9 @@ export async function runTask(workerScript: string, taskData: T): Promise< try { return await new Promise((resolve, reject) => { worker.on('message', (result: R) => { + if ((result as any)?.error) { + reject(new Error((result as { error: string }).error)); + } resolve(result); });