new import payload error code

Author: nicktrn

packages/core/src/v3/schemas/common.ts

@@ -98,6 +98,7 @@ export const TaskRunErrorCodes = {
   DISK_SPACE_EXCEEDED: "DISK_SPACE_EXCEEDED",
   POD_EVICTED: "POD_EVICTED",
   POD_UNKNOWN_ERROR: "POD_UNKNOWN_ERROR",
+  IMPORT_PAYLOAD_ERROR: "IMPORT_PAYLOAD_ERROR",
 } as const;
 
 export const TaskRunInternalError = z.object({
@@ -124,6 +125,7 @@ export const TaskRunInternalError = z.object({
     "DISK_SPACE_EXCEEDED",
     "POD_EVICTED",
     "POD_UNKNOWN_ERROR",
+    "IMPORT_PAYLOAD_ERROR",
   ]),
   message: z.string().optional(),
   stackTrace: z.string().optional(),

packages/core/src/v3/workers/taskExecutor.ts

@@ -92,9 +92,28 @@ export class TaskExecutor {
 
           try {
             const payloadPacket = await conditionallyImportPacket(originalPacket, this._tracer);
-
             parsedPayload = await parsePacket(payloadPacket);
+          } catch (packetError) {
+            recordSpanException(span, packetError);
+
+            return {
+              ok: false,
+              id: execution.run.id,
+              error: {
+                type: "INTERNAL_ERROR",
+                code: TaskRunErrorCodes.IMPORT_PAYLOAD_ERROR,
+                message:
+                  packetError instanceof Error
+                    ? `${packetError.name}: ${packetError.message}`
+                    : typeof packetError === "string"
+                    ? packetError
+                    : undefined,
+                stackTrace: packetError instanceof Error ? packetError.stack : undefined,
+              },
+            } satisfies TaskRunExecutionResult;
+          }
 
+          try {
             if (execution.attempt.number === 1) {
               await this.#callOnStartFunctions(parsedPayload, ctx, signal);
             }