Mo-Stashed changes

Author: ericallam

apps/webapp/app/routes/resources.taskruns.$runParam.replay.ts

@@ -108,6 +108,10 @@ export async function loader({ request, params }: LoaderFunctionArgs) {
   const disableVersionSelection = environment.type === "DEVELOPMENT";
   const allowArbitraryQueues = backgroundWorkers.at(0)?.engine === "V1";
 
+  const payload = await prettyPrintPacket(run.payload, run.payloadType, {
+    cloneCircularReferences: false,
+  });
+
   return typedjson({
     concurrencyKey: run.concurrencyKey,
     maxAttempts: run.maxAttempts,
@@ -116,7 +120,7 @@ export async function loader({ request, params }: LoaderFunctionArgs) {
     ttlSeconds: run.ttl ? parseDuration(run.ttl, "s") ?? undefined : undefined,
     idempotencyKey: run.idempotencyKey,
     runTags: run.runTags,
-    payload: await prettyPrintPacket(run.payload, run.payloadType),
+    payload,
     payloadType: run.payloadType,
     queue: run.queue,
     metadata: run.seedMetadata

packages/core/src/v3/utils/ioSerialization.ts

@@ -391,7 +391,7 @@ export async function prettyPrintPacket(
     }
     const { deserialize } = await loadSuperJSON();
 
-    return await prettyPrintPacket(deserialize(rawData), "application/json");
+    return await prettyPrintPacket(deserialize(rawData), "application/json", options);
   }
 
   if (dataType === "application/json") {
@@ -410,6 +410,7 @@ export async function prettyPrintPacket(
 
 interface ReplacerOptions {
   filteredKeys?: string[];
+  cloneCircularReferences?: boolean;
 }
 
 function makeSafeReplacer(options?: ReplacerOptions) {
@@ -418,6 +419,10 @@ function makeSafeReplacer(options?: ReplacerOptions) {
   return function replacer(key: string, value: any) {
     if (typeof value === "object" && value !== null) {
       if (seen.has(value)) {
+        if (options?.cloneCircularReferences) {
+          return structuredClone(value);
+        }
+
         return "[Circular]";
       }
       seen.add(value);

references/hello-world/src/trigger/circularPayload.ts

@@ -0,0 +1,34 @@
+import { logger, task } from "@trigger.dev/sdk";
+
+export const circularPayloadParentTask = task({
+  id: "circular-payload-parent",
+  run: async (payload: any) => {
+    const circularReferencePayload = {
+      name: "Alice",
+      details: {
+        age: 30,
+        email: "alice@example.com",
+      },
+    };
+
+    // @ts-expect-error - This is a circular reference
+    circularReferencePayload.details.user = circularReferencePayload;
+
+    await circularPayloadChildTask.triggerAndWait(circularReferencePayload);
+
+    return {
+      message: "Hello, world!",
+    };
+  },
+});
+
+export const circularPayloadChildTask = task({
+  id: "circular-payload-child",
+  run: async (payload: any) => {
+    logger.log("response", { response: payload.response });
+
+    return {
+      message: "Hello, world!",
+    };
+  },
+});