diff --git a/apps/webapp/app/presenters/v3/ApiRetrieveRunPresenter.server.ts b/apps/webapp/app/presenters/v3/ApiRetrieveRunPresenter.server.ts index 06f1a4c538..5fcae91120 100644 --- a/apps/webapp/app/presenters/v3/ApiRetrieveRunPresenter.server.ts +++ b/apps/webapp/app/presenters/v3/ApiRetrieveRunPresenter.server.ts @@ -7,8 +7,8 @@ import { conditionallyImportPacket, createJsonErrorObject, logger, - parsePacket, } from "@trigger.dev/core/v3"; +import { parsePacketAsJson } from "@trigger.dev/core/v3/utils/ioSerialization"; import { Prisma, TaskRunAttemptStatus, TaskRunStatus } from "@trigger.dev/database"; import assertNever from "assert-never"; import { API_VERSIONS, CURRENT_API_VERSION, RunStatusUnspecifiedApiVersion } from "~/api/versions"; @@ -133,7 +133,7 @@ export class ApiRetrieveRunPresenter { }); } } else { - $payload = await parsePacket(payloadPacket); + $payload = await parsePacketAsJson(payloadPacket); } if (taskRun.status === "COMPLETED_SUCCESSFULLY") { @@ -162,7 +162,7 @@ export class ApiRetrieveRunPresenter { }); } } else { - $output = await parsePacket(outputPacket); + $output = await parsePacketAsJson(outputPacket); } } @@ -433,7 +433,7 @@ async function resolveSchedule(run: CommonRelatedRun) { } async function createCommonRunStructure(run: CommonRelatedRun, apiVersion: API_VERSIONS) { - const metadata = await parsePacket({ + const metadata = await parsePacketAsJson({ data: run.metadata ?? undefined, dataType: run.metadataType, }); diff --git a/references/hello-world/src/trigger/example.ts b/references/hello-world/src/trigger/example.ts index 7f476dbcfd..6d1622df28 100644 --- a/references/hello-world/src/trigger/example.ts +++ b/references/hello-world/src/trigger/example.ts @@ -58,7 +58,7 @@ export const parentTask = task({ machine: "medium-1x", run: async (payload: any, { ctx }) => { logger.log("Hello, world from the parent", { payload }); - await childTask.triggerAndWait({ message: "Hello, world!" }); + await childTask.triggerAndWait({ message: "Hello, world!", aReallyBigInt: BigInt(10000) }); }, }); @@ -103,10 +103,11 @@ export const childTask = task({ message, failureChance = 0.3, duration = 3_000, - }: { message?: string; failureChance?: number; duration?: number }, + aReallyBigInt, + }: { message?: string; failureChance?: number; duration?: number; aReallyBigInt?: bigint }, { ctx } ) => { - logger.info("Hello, world from the child", { message, failureChance }); + logger.info("Hello, world from the child", { message, failureChance, aReallyBigInt }); if (Math.random() < failureChance) { throw new Error("Random error at start");