Add taskId and runId to SubtaskUnwrapError

Author: ericallam

packages/trigger-sdk/src/v3/shared.ts

@@ -264,14 +264,20 @@ export type TaskRunResult<TOutput = any> =
     };
 
 export class SubtaskUnwrapError extends Error {
-  constructor(taskId: string, subtaskError: unknown) {
+  public readonly taskId: string;
+  public readonly runId: string;
+
+  constructor(taskId: string, runId: string, subtaskError: unknown) {
     if (subtaskError instanceof Error) {
       super(`Error in ${taskId}: ${subtaskError.message}`, { cause: subtaskError });
       this.name = "SubtaskUnwrapError";
     } else {
       super(`Error in ${taskId}`, { cause: subtaskError });
       this.name = "SubtaskUnwrapError";
     }
+
+    this.taskId = taskId;
+    this.runId = runId;
   }
 }
 
@@ -291,7 +297,7 @@ export class TaskRunPromise<T> extends Promise<TaskRunResult<T>> {
       if (result.ok) {
         return result.output;
       } else {
-        throw new SubtaskUnwrapError(this.taskId, result.error);
+        throw new SubtaskUnwrapError(this.taskId, result.id, result.error);
       }
     });
   }

references/v3-catalog/src/trigger/simple.ts

@@ -31,13 +31,17 @@ export const fetchPostTask = task({
 export const anyPayloadTask = task({
   id: "any-payload-task",
   run: async (payload: any) => {
-    const { url, method } = await tasks
-      .triggerAndWait<typeof fetchPostTask>("fetch-post-task", {
-        url: "https://jsonplaceholder.typicode.comasdqdasd/posts/1",
-      })
-      .unwrap();
-
-    console.log("Result from fetch-post-task 211111sss", { output: { url, method } });
+    try {
+      const { url, method } = await tasks
+        .triggerAndWait<typeof fetchPostTask>("fetch-post-task", {
+          url: "https://jsonplaceholder.typicode.comasdqdasd/posts/1",
+        })
+        .unwrap();
+
+      console.log("Result from fetch-post-task 211111sss", { output: { url, method } });
+    } catch (error) {
+      console.error("Error in fetch-post-task", { error });
+    }
 
     return {
       payload,