Update pnpm lock file

chore: Update version for release (beta) (#984 )
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
2024-03-28 19:55:14 +00:00 · 2024-03-28 19:54:21 +00:00 · 2024-03-28 19:51:29 +00:00 · 2024-03-28 18:14:47 +00:00 · 2024-03-28 18:12:01 +00:00
82 changed files with 497 additions and 205 deletions
@@ -0,0 +1,6 @@
+---
+"trigger.dev": patch
+"@trigger.dev/core": patch
+---
+
+Handle string and non-stringifiable outputs like functions
@@ -48,6 +48,7 @@
    "clean-pianos-listen",
    "lemon-jobs-repair",
    "light-bulldogs-press",
+    "many-ligers-pump",
    "real-planets-stare",
    "strange-ghosts-matter",
    "stupid-bulldogs-applaud",
@@ -64,4 +64,12 @@ COORDINATOR_SECRET=coordinator-secret # generate the actual secret with `openssl
 # OBJECT_STORE_BASE_URL="https://{bucket}.{accountId}.r2.cloudflarestorage.com"
 # OBJECT_STORE_ACCESS_KEY_ID=
 # OBJECT_STORE_SECRET_ACCESS_KEY=
-# RUNTIME_WAIT_THRESHOLD_IN_MS=10000
+# RUNTIME_WAIT_THRESHOLD_IN_MS=10000
+
+# These control the server-side internal telemetry
+# INTERNAL_OTEL_TRACE_EXPORTER_URL=<URL to send traces to>
+# INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_NAME=<Header name for the auth token>
+# INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_VALUE=<Auth token value>
+# INTERNAL_OTEL_TRACE_LOGGING_ENABLED=1
+# INTERNAL_OTEL_TRACE_SAMPING_RATE=20 # this means 1/20 traces or 5% of traces will be sampled (sampled = recorded)
+# INTERNAL_OTEL_TRACE_INSTRUMENT_PRISMA_ENABLED=0,
@@ -182,11 +182,3 @@ export { apiRateLimiter } from "./services/apiRateLimit.server";
 export { socketIo } from "./v3/handleSocketIo.server";
 export { wss } from "./v3/handleWebsockets.server";
 export { registryProxy } from "./v3/registryProxy.server";
-
-process.on("uncaughtException", (error, origin) => {
-  logger.error("Uncaught Exception", { error, origin });
-});
-
-process.on("unhandledRejection", (reason, promise) => {
-  logger.error("Unhandled Rejection", { reason });
-});
@@ -85,8 +85,6 @@ const EnvironmentSchema = z.object({

  //v3
  V3_ENABLED: z.string().default("false"),
-  OTLP_EXPORTER_TRACES_URL: z.string().optional(),
-  LOG_TELEMETRY: z.string().default("true"),
  IMAGE_REGISTRY: z.string().default("docker.io"),
  IMAGE_REPO: z.string().default("task"),
  PROVIDER_SECRET: z.string().default("provider-secret"),
@@ -117,6 +115,15 @@ const EnvironmentSchema = z.object({
  DEV_OTEL_LOG_EXPORT_TIMEOUT_MILLIS: z.string().default("30000"),
  DEV_OTEL_LOG_MAX_QUEUE_SIZE: z.string().default("512"),
  RUNTIME_WAIT_THRESHOLD_IN_MS: z.coerce.number().int().default(30000),
+
+  // Internal OTEL environment variables
+  INTERNAL_OTEL_TRACE_EXPORTER_URL: z.string().optional(),
+  INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_NAME: z.string().optional(),
+  INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_VALUE: z.string().optional(),
+  INTERNAL_OTEL_TRACE_LOGGING_ENABLED: z.string().default("1"),
+  // this means 1/20 traces or 5% of traces will be sampled (sampled = recorded)
+  INTERNAL_OTEL_TRACE_SAMPING_RATE: z.string().default("20"),
+  INTERNAL_OTEL_TRACE_INSTRUMENT_PRISMA_ENABLED: z.string().default("0"),
 });

 export type Environment = z.infer<typeof EnvironmentSchema>;
@@ -69,7 +69,8 @@ export class TestTaskPresenter {
      ON
          tr."taskIdentifier" = bwt.slug
      WHERE
-          bwt."friendlyId" = ${taskFriendlyId}
+          bwt."friendlyId" = ${taskFriendlyId} AND
+          tr."runtimeEnvironmentId" = ${task.runtimeEnvironment.id}
      ORDER BY 
          tr."createdAt" DESC
      LIMIT 5
@@ -222,19 +222,25 @@ function PacketDisplay({
  dataType: string;
  title: string;
 }) {
-  if (dataType === "application/store") {
-    return (
-      <div className="flex flex-col">
-        <Paragraph variant="base/bright" className="w-full border-b border-grid-dimmed py-2.5">
-          {title}
-        </Paragraph>
-        <LinkButton LeadingIcon={CloudArrowDownIcon} to={data} variant="tertiary/medium" download>
-          Download
-        </LinkButton>
-      </div>
-    );
-  } else {
-    return <CodeBlock rowTitle={title} code={data} maxLines={20} />;
+  switch (dataType) {
+    case "application/store": {
+      return (
+        <div className="flex flex-col">
+          <Paragraph variant="base/bright" className="w-full border-b border-grid-dimmed py-2.5">
+            {title}
+          </Paragraph>
+          <LinkButton LeadingIcon={CloudArrowDownIcon} to={data} variant="tertiary/medium" download>
+            Download
+          </LinkButton>
+        </div>
+      );
+    }
+    case "text/plain": {
+      return <CodeBlock language="markdown" rowTitle={title} code={data} maxLines={20} />;
+    }
+    default: {
+      return <CodeBlock language="json" rowTitle={title} code={data} maxLines={20} />;
+    }
  }
 }

@@ -10,7 +10,7 @@ import {
  SpanMessagingEvent,
  TaskEventStyle,
  correctErrorStackTrace,
-  createPackageAttributesAsJson,
+  createPacketAttributesAsJson,
  flattenAttributes,
  isExceptionSpanEvent,
  omit,
@@ -188,7 +188,7 @@ export class EventRepository {
    const event = events[0];

    const output = options?.attributes.output
-      ? await createPackageAttributesAsJson(
+      ? await createPacketAttributesAsJson(
          options?.attributes.output,
          options?.attributes.outputType ?? "application/json"
        )
@@ -213,8 +213,9 @@ export class EventRepository {
      style: event.style as Attributes,
      output: output,
      outputType:
-        options?.attributes.outputType === "application/store"
-          ? "application/store"
+        options?.attributes.outputType === "application/store" ||
+        options?.attributes.outputType === "text/plain"
+          ? options?.attributes.outputType
          : "application/json",
      payload: event.payload as Attributes,
      payloadType: event.payloadType,
@@ -105,7 +105,7 @@ export class CompleteAttemptService extends BaseService {
      attributes: {
        isError: false,
        output:
-          completion.outputType === "application/store"
+          completion.outputType === "application/store" || completion.outputType === "text/plain"
            ? completion.output
            : completion.output
            ? (safeJsonParse(completion.output) as Attributes)
@@ -9,7 +9,7 @@ import {
  trace,
 } from "@opentelemetry/api";
 import { OTLPTraceExporter } from "@opentelemetry/exporter-trace-otlp-http";
-import { registerInstrumentations } from "@opentelemetry/instrumentation";
+import { InstrumentationOption, registerInstrumentations } from "@opentelemetry/instrumentation";
 import { ExpressInstrumentation } from "@opentelemetry/instrumentation-express";
 import { HttpInstrumentation } from "@opentelemetry/instrumentation-http";
 import { Resource } from "@opentelemetry/resources";
@@ -23,12 +23,13 @@ import {
  TraceIdRatioBasedSampler,
 } from "@opentelemetry/sdk-trace-base";
 import { NodeTracerProvider } from "@opentelemetry/sdk-trace-node";
-import { SemanticResourceAttributes } from "@opentelemetry/semantic-conventions";
+import { SEMRESATTRS_SERVICE_NAME } from "@opentelemetry/semantic-conventions";
 import { PrismaInstrumentation } from "@prisma/instrumentation";
 import { env } from "~/env.server";
 import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
 import { singleton } from "~/utils/singleton";
 import { LoggerSpanExporter } from "./telemetry/loggerExporter.server";
+
 class CustomWebappSampler implements Sampler {
  constructor(private readonly _baseSampler: Sampler) {}

@@ -44,10 +45,7 @@ class CustomWebappSampler implements Sampler {
    const parentContext = trace.getSpanContext(context);

    // Exclude Prisma spans (adjust this logic as needed for your use case)
-    if (
-      !parentContext &&
-      ((attributes && attributes["model"] && attributes["method"]) || name.includes("prisma"))
-    ) {
+    if (!parentContext && name.includes("prisma")) {
      return { decision: SamplingDecision.NOT_RECORD };
    }

@@ -65,29 +63,46 @@ export const tracer = singleton("tracer", getTracer);
 function getTracer() {
  diag.setLogger(new DiagConsoleLogger(), DiagLogLevel.ERROR);

+  const samplingRate = 1.0 / Math.max(parseInt(env.INTERNAL_OTEL_TRACE_SAMPING_RATE, 10), 1);
+
  const provider = new NodeTracerProvider({
    forceFlushTimeoutMillis: 500,
    resource: new Resource({
-      [SemanticResourceAttributes.SERVICE_NAME]: "trigger.dev",
+      [SEMRESATTRS_SERVICE_NAME]: "trigger.dev",
    }),
    sampler: new ParentBasedSampler({
-      root: new CustomWebappSampler(
-        new TraceIdRatioBasedSampler(env.APP_ENV === "development" ? 1.0 : 0.05)
-      ), // 5% sampling
+      root: new CustomWebappSampler(new TraceIdRatioBasedSampler(samplingRate)), // 5% sampling
    }), // 5% sampling
  });

-  if (env.OTLP_EXPORTER_TRACES_URL) {
+  if (env.INTERNAL_OTEL_TRACE_EXPORTER_URL) {
    const exporter = new OTLPTraceExporter({
-      url: env.OTLP_EXPORTER_TRACES_URL,
+      url: env.INTERNAL_OTEL_TRACE_EXPORTER_URL,
      timeoutMillis: 1000,
+      headers:
+        env.INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_NAME &&
+        env.INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_VALUE
+          ? {
+              [env.INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_NAME]:
+                env.INTERNAL_OTEL_TRACE_EXPORTER_AUTH_HEADER_VALUE,
+            }
+          : undefined,
    });

-    provider.addSpanProcessor(new BatchSpanProcessor(exporter));
+    provider.addSpanProcessor(
+      new BatchSpanProcessor(exporter, {
+        maxExportBatchSize: 512,
+        scheduledDelayMillis: 200,
+        exportTimeoutMillis: 30000,
+        maxQueueSize: 2048,
+      })
+    );

-    console.log(`⚡ Tracer: OTLP exporter enabled to ${env.OTLP_EXPORTER_TRACES_URL}`);
+    console.log(`🔦 Tracer: OTLP exporter enabled to ${env.INTERNAL_OTEL_TRACE_EXPORTER_URL}`);
  } else {
-    if (env.LOG_TELEMETRY === "true") {
+    if (env.INTERNAL_OTEL_TRACE_LOGGING_ENABLED === "1") {
+      console.log(`🔦 Tracer: Logger exporter enabled`);
+
      const loggerExporter = new LoggerSpanExporter();

      provider.addSpanProcessor(new SimpleSpanProcessor(loggerExporter));
@@ -96,13 +111,18 @@ function getTracer() {

  provider.register();

+  let instrumentations: InstrumentationOption[] = [
+    new HttpInstrumentation(),
+    new ExpressInstrumentation(),
+  ];
+
+  if (env.INTERNAL_OTEL_TRACE_INSTRUMENT_PRISMA_ENABLED === "1") {
+    instrumentations.push(new PrismaInstrumentation());
+  }
+
  registerInstrumentations({
    tracerProvider: provider,
-    instrumentations: [
-      new HttpInstrumentation(),
-      new ExpressInstrumentation(),
-      new PrismaInstrumentation(),
-    ],
+    instrumentations,
  });

  return provider.getTracer("trigger.dev", "3.0.0.dp.1");
@@ -1,5 +1,12 @@
 # @trigger.dev/airtable

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/airtable",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for airtable",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "airtable": "^0.12.1",
    "zod": "3.22.3"
  },
@@ -1,5 +1,12 @@
 # @trigger.dev/github

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/github",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official GitHub integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -30,8 +30,8 @@
    "@octokit/request-error": "^5.0.1",
    "@octokit/webhooks": "^12.0.10",
    "octokit": "^3.1.2",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "zod": "3.22.3"
  },
  "engines": {
@@ -1,5 +1,12 @@
 # @trigger.dev/linear

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/linear",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for @linear/sdk",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
  },
  "dependencies": {
    "@linear/sdk": "^8.0.0",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "zod": "3.22.3"
  },
  "engines": {
@@ -1,5 +1,12 @@
 # @trigger.dev/slack

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/openai",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official OpenAI integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -42,8 +42,8 @@
  },
  "dependencies": {
    "openai": "^4.16.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2"
  },
  "engines": {
    "node": ">=18.0.0"
@@ -1,5 +1,12 @@
 # @trigger.dev/plain

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/plain",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official Plain.com integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
    "build:tsup": "tsup"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "@team-plain/typescript-sdk": "^2.7.0"
  },
  "engines": {
@@ -1,5 +1,12 @@
 # @trigger.dev/replicate

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/replicate",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for replicate",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "replicate": "^0.18.1",
    "zod": "3.22.3"
  },
@@ -1,5 +1,12 @@
 # @trigger.dev/resend

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/resend",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official Resend.com integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
    "build:tsup": "tsup"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "resend": "^2.1.0"
  },
  "engines": {
@@ -1,5 +1,12 @@
 # @trigger.dev/sendgrid

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/sendgrid",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for @sendgrid/mail",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
  },
  "dependencies": {
    "@sendgrid/mail": "^7.7.0",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2"
  },
  "engines": {
    "node": ">=16.8.0"
@@ -1,5 +1,12 @@
 # @trigger.dev/shopify

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/shopify",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for @shopify/shopify-api",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
  },
  "dependencies": {
    "@shopify/shopify-api": "^8.0.2",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
    "zod": "3.22.3"
  },
  "engines": {
@@ -1,5 +1,11 @@
 # @trigger.dev/slack

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/slack",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official Slack integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -25,7 +25,7 @@
  },
  "dependencies": {
    "@slack/web-api": "^6.8.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "zod": "3.22.3"
  },
  "engines": {
@@ -1,5 +1,12 @@
 # @trigger.dev/stripe

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/stripe",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for stripe",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "stripe": "^12.14.0",
    "zod": "3.22.3"
  },
@@ -1,5 +1,12 @@
 # @trigger.dev/supabase

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/supabase",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev integration for @supabase/supabase-js",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
  },
  "dependencies": {
    "@supabase/supabase-js": "^2.26.0",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "supabase-management-js": "^1.0.0",
    "zod": "3.22.3"
  },
@@ -1,5 +1,12 @@
 # @trigger.dev/typeform

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.2
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/typeform",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The official Typeform integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "@typeform/api-client": "^1.8.0",
    "zod": "3.22.3"
  },
@@ -1,5 +1,11 @@
 # @trigger.dev/astro

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,7 +1,7 @@
 {
  "name": "@trigger.dev/astro",
  "description": "An Astro-native integration for Trigger.dev background jobs platform",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
  "files": [
@@ -20,7 +20,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2"
  },
  "devDependencies": {
    "astro": "^3.0.12",
@@ -1,5 +1,13 @@
 # trigger.dev

+## 3.0.0-beta.3
+
+### Patch Changes
+
+- e3cf456c6: Handle string and non-stringifiable outputs like functions
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+
 ## 3.0.0-beta.2

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "trigger.dev",
-  "version": "3.0.0-beta.2",
+  "version": "3.0.0-beta.3",
  "description": "A Command-Line Interface for Trigger.dev (v3) projects",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -89,7 +89,7 @@
    "@opentelemetry/sdk-trace-base": "^1.22.0",
    "@opentelemetry/sdk-trace-node": "^1.22.0",
    "@opentelemetry/semantic-conventions": "^1.22.0",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.2",
    "@types/degit": "^2.8.3",
    "chalk": "^5.2.0",
    "chokidar": "^3.5.3",
@@ -26,7 +26,7 @@ import * as packageJson from "../../package.json";
 import { CliApiClient } from "../apiClient";
 import { CommonCommandOptions, commonOptions, wrapCommandAction } from "../cli/common.js";
 import { bundleDependenciesPlugin, workerSetupImportConfigPlugin } from "../utilities/build";
-import { chalkGrey, chalkPurple, chalkWorker } from "../utilities/cliOutput";
+import { chalkError, chalkGrey, chalkPurple, chalkTask, chalkWorker } from "../utilities/cliOutput";
 import { readConfig } from "../utilities/configFiles";
 import { readJSONFile } from "../utilities/fileSystem";
 import { printDevBanner, printStandloneInitialBanner } from "../utilities/initialBanner.js";
@@ -77,9 +77,13 @@ export async function devCommand(dir: string, options: DevCommandOptions) {

  if (!authorization.ok) {
    if (authorization.error === "fetch failed") {
-      logger.error("Fetch failed. Platform down?");
+      logger.log(
+        `${chalkError(
+          "X Error:"
+        )} Connecting to the server failed. Please check your internet connection or contact eric@trigger.dev for help.`
+      );
    } else {
-      logger.error("You must login first. Use `trigger.dev login` to login.");
+      logger.log(`${chalkError("X Error:")} You must login first. Use the \`login\` CLI command.`);
    }
    process.exitCode = 1;
    return;
@@ -701,13 +705,13 @@ function createDuplicateTaskIdOutputErrorMessage(
    .map((id) => {
      const tasks = taskResources.filter((task) => task.id === id);

-      return `id "${chalkPurple(id)}" was found in:\n${tasks
-        .map((task) => `${task.filePath} -> ${task.exportName}`)
-        .join("\n")}`;
+      return `\n\n${chalkTask(id)} was found in:${tasks
+        .map((task) => `\n${task.filePath} -> ${task.exportName}`)
+        .join("")}`;
    })
-    .join("\n\n");
+    .join("");

-  return `Duplicate task ids detected:\n\n${duplicateTable}\n\n`;
+  return `Duplicate ${chalkTask("task id")} detected:${duplicateTable}`;
 }

 function gatherProcessEnv() {
@@ -18,16 +18,11 @@ import {
  formatDurationMilliseconds,
  workerToChildMessages,
 } from "@trigger.dev/core/v3";
-import chalk from "chalk";
 import dotenv from "dotenv";
 import { Evt } from "evt";
 import { ChildProcess, fork } from "node:child_process";
 import { dirname, resolve } from "node:path";
 import terminalLink from "terminal-link";
-import { safeDeleteFileSync } from "../../utilities/fileSystem.js";
-import { installPackages } from "../../utilities/installPackages.js";
-import { logger } from "../../utilities/logger.js";
-import { UncaughtExceptionError } from "../common/errors.js";
 import {
  chalkError,
  chalkGrey,
@@ -39,6 +34,10 @@ import {
  chalkWorker,
  prettyPrintDate,
 } from "../../utilities/cliOutput.js";
+import { safeDeleteFileSync } from "../../utilities/fileSystem.js";
+import { installPackages } from "../../utilities/installPackages.js";
+import { logger } from "../../utilities/logger.js";
+import { UncaughtExceptionError } from "../common/errors.js";

 export type CurrentWorkers = BackgroundWorkerCoordinator["currentWorkers"];
 export class BackgroundWorkerCoordinator {
@@ -1,5 +1,13 @@
 # create-trigger

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+  - @trigger.dev/yalt@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/cli",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "The Trigger.dev CLI",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -1,5 +1,7 @@
 # @trigger.dev/core-apps

+## 3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,7 +1,7 @@
 {
  "name": "@trigger.dev/core-apps",
  "description": "Backend core code used across apps",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "private": true,
  "license": "MIT",
  "main": "./dist/index.js",
@@ -1,5 +1,7 @@
 # @trigger.dev/core-backend

+## 3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ## 3.0.0-beta.0
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/core-backend",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Core code used across `@trigger.dev/sdk` and Trigger.dev server",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -94,20 +94,22 @@ export class Logger {
    ...args: Array<Record<string, unknown> | undefined>
  ) {
    // Get the current context from trace if it exists
-    const currentContext = trace.getSpan(context.active());
+    const currentSpan = trace.getSpan(context.active());

-    const structuredLog = {
-      ...structureArgs(safeJsonClone(args) as Record<string, unknown>[], this.#filteredKeys),
-      ...this.#additionalFields(),
-      timestamp: new Date(),
-      name: this.#name,
-      message,
-      level,
-      traceId: currentContext?.spanContext().traceId,
-      parentSpanId: currentContext?.spanContext().spanId,
-    };
+    if (!currentSpan || currentSpan.isRecording()) {
+      const structuredLog = {
+        ...structureArgs(safeJsonClone(args) as Record<string, unknown>[], this.#filteredKeys),
+        ...this.#additionalFields(),
+        timestamp: new Date(),
+        name: this.#name,
+        message,
+        level,
+        traceId: currentSpan?.spanContext().traceId,
+        parentSpanId: currentSpan?.spanContext().spanId,
+      };

-    loggerFunction(JSON.stringify(structuredLog, this.#jsonReplacer));
+      loggerFunction(JSON.stringify(structuredLog, this.#jsonReplacer));
+    }
  }
 }

@@ -1,5 +1,11 @@
 # internal-platform

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- e3cf456c6: Handle string and non-stringifiable outputs like functions
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/core",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Core code used across the Trigger.dev SDK and platform",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -64,7 +64,7 @@ export {
  stringifyIO,
  prettyPrintPacket,
  createPacketAttributes,
-  createPackageAttributesAsJson,
+  createPacketAttributesAsJson,
  conditionallyExportPacket,
  conditionallyImportPacket,
  packetRequiresOffloading,
@@ -42,9 +42,14 @@ export async function stringifyIO(value: any): Promise<IOPacket> {
    return { data: value, dataType: "text/plain" };
  }

-  const { stringify } = await loadSuperJSON();
+  try {
+    const { stringify } = await loadSuperJSON();
+    const data = stringify(value);

-  return { data: stringify(value), dataType: "application/super+json" };
+    return { data, dataType: "application/super+json" };
+  } catch {
+    return { dataType: "application/json" };
+  }
 }

 export async function conditionallyExportPacket(
@@ -193,9 +198,9 @@ export async function createPacketAttributes(
  packet: IOPacket,
  dataKey: string,
  dataTypeKey: string
-): Promise<Attributes> {
+): Promise<Attributes | undefined> {
  if (!packet.data) {
-    return {};
+    return;
  }

  switch (packet.dataType) {
@@ -207,13 +212,22 @@ export async function createPacketAttributes(
    case "application/super+json":
      const { parse } = await loadSuperJSON();

-      const parsed = parse(packet.data) as any;
-      const jsonified = JSON.parse(JSON.stringify(parsed, safeReplacer));
+      if (typeof packet.data === "undefined" || packet.data === null) {
+        return;
+      }
+
+      try {
+        const parsed = parse(packet.data) as any;
+        const jsonified = JSON.parse(JSON.stringify(parsed, safeReplacer));
+
+        return {
+          ...flattenAttributes(jsonified, dataKey),
+          [dataTypeKey]: "application/json",
+        };
+      } catch {
+        return;
+      }

-      return {
-        ...flattenAttributes(jsonified, dataKey),
-        [dataTypeKey]: "application/json",
-      };
    case "application/store":
      return {
        [dataKey]: packet.data,
@@ -221,15 +235,15 @@ export async function createPacketAttributes(
      };
    case "text/plain":
      return {
-        [SemanticInternalAttributes.OUTPUT]: packet.data,
-        [SemanticInternalAttributes.OUTPUT_TYPE]: packet.dataType,
+        [dataKey]: packet.data,
+        [dataTypeKey]: packet.dataType,
      };
    default:
-      return {};
+      return;
  }
 }

-export async function createPackageAttributesAsJson(
+export async function createPacketAttributesAsJson(
  data: any,
  dataType: string
 ): Promise<Attributes> {
@@ -250,7 +264,7 @@ export async function createPackageAttributesAsJson(
      const { deserialize } = await loadSuperJSON();

      const deserialized = deserialize(data) as any;
-      const jsonify = JSON.parse(JSON.stringify(deserialized, safeReplacer));
+      const jsonify = safeJsonParse(JSON.stringify(deserialized, safeReplacer));

      return imposeAttributeLimits(flattenAttributes(jsonify, undefined));
    case "application/store":
@@ -326,3 +340,11 @@ function getPacketExtension(outputType: string): string {
 async function loadSuperJSON(): Promise<typeof import("superjson")> {
  return await import("superjson");
 }
+
+function safeJsonParse(value: string): any {
+  try {
+    return JSON.parse(value);
+  } catch {
+    return;
+  }
+}
@@ -104,14 +104,16 @@ export class TaskExecutor {
                    this._tracer
                  );

-                  span.setAttributes(
-                    await createPacketAttributes(
-                      finalOutput,
-                      SemanticInternalAttributes.OUTPUT,
-                      SemanticInternalAttributes.OUTPUT_TYPE
-                    )
+                  const attributes = await createPacketAttributes(
+                    finalOutput,
+                    SemanticInternalAttributes.OUTPUT,
+                    SemanticInternalAttributes.OUTPUT_TYPE
                  );

+                  if (attributes) {
+                    span.setAttributes(attributes);
+                  }
+
                  return {
                    ok: true,
                    id: execution.attempt.id,
@@ -1,5 +1,7 @@
 # @trigger.dev/eslint-plugin

+## 3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ## 3.0.0-beta.0
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/eslint-plugin",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "ESLint plugin with trigger.dev best practices",
  "keywords": [
    "eslint",
@@ -1,5 +1,11 @@
 # @trigger.dev/express

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/express",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Official Express adapter for Trigger.dev",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -23,7 +23,7 @@
    "./package.json": "./package.json"
  },
  "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "@trigger.dev/tsconfig": "workspace:*",
    "@types/debug": "^4.1.7",
    "@types/express": "^4.17.13",
@@ -39,7 +39,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2"
  },
  "dependencies": {
    "debug": "^4.3.4",
@@ -1,5 +1,11 @@
 # @trigger.dev/hono

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/hono",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "A Trigger.dev adapter for Hono.dev",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -32,7 +32,7 @@
  },
  "peerDependencies": {
    "hono": "3.x",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2"
  },
  "devDependencies": {
    "@trigger.dev/tsconfig": "workspace:*",
@@ -1,5 +1,12 @@
 # @trigger.dev/integration-kit

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/integration-kit",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev Integration Kit has helpers to make creating integrations easier",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -1,5 +1,11 @@
 # @trigger.dev/nestjs

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/nestjs",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Official NestJS adapter for Trigger.dev",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -23,7 +23,7 @@
    "./package.json": "./package.json"
  },
  "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "@trigger.dev/tsconfig": "workspace:*",
    "@types/debug": "^4.1.7",
    "@types/express": "^4.17.13",
@@ -41,7 +41,7 @@
  },
  "peerDependencies": {
    "@nestjs/common": ">=10.0.0",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2"
  },
  "dependencies": {
    "@nestjs/common": "^10.2.4",
@@ -1,5 +1,11 @@
 # @trigger.dev/nextjs

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/nextjs",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev Next.js integration",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -41,7 +41,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "next": ">=12.0.0"
  },
  "dependencies": {
@@ -1,5 +1,7 @@
 # @trigger.dev/otlp-importer

+## 3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ## 3.0.0-beta.0
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/otlp-importer",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "OpenTelemetry OTLP Importer for Node.js written in TypeScript",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -1,5 +1,12 @@
 # @trigger.dev/react

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/react",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev React SDK",
  "license": "MIT",
  "types": "dist/index.d.ts",
@@ -27,7 +27,7 @@
  },
  "dependencies": {
    "@tanstack/react-query": "5.0.0-beta.2",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.2",
    "debug": "^4.3.4",
    "zod": "3.22.3"
  },
@@ -1,5 +1,11 @@
 # @trigger.dev/remix

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/remix",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev Remix integration",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -39,7 +39,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2",
    "@remix-run/server-runtime": ">1.19.0"
  },
  "dependencies": {
@@ -1,5 +1,11 @@
 # @trigger.dev/sveltekit

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/sveltekit",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "Trigger.dev svelteKit integration",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -39,7 +39,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.1"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.2"
  },
  "dependencies": {
    "debug": "^4.3.4"
@@ -1,5 +1,13 @@
 # @trigger.dev/testing

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+  - @trigger.dev/sdk@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,7 +1,7 @@
 {
  "name": "@trigger.dev/testing",
  "description": "A collection of useful tools to write tests for Trigger.dev.",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "license": "MIT",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -1,5 +1,13 @@
 # @trigger.dev/sdk

+## 3.0.0-beta.2
+
+### Patch Changes
+
+- Updated dependencies [e3cf456c6]
+  - @trigger.dev/core@3.0.0-beta.2
+  - @trigger.dev/core-backend@3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/sdk",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "trigger.dev Node.JS SDK",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -48,8 +48,8 @@
    "@opentelemetry/api": "^1.8.0",
    "@opentelemetry/api-logs": "^0.48.0",
    "@opentelemetry/semantic-conventions": "^1.22.0",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.1",
-    "@trigger.dev/core-backend": "workspace:^3.0.0-beta.1",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.2",
+    "@trigger.dev/core-backend": "workspace:^3.0.0-beta.2",
    "chalk": "^5.2.0",
    "cronstrue": "^2.21.0",
    "debug": "^4.3.4",
@@ -1,5 +1,7 @@
 # @trigger.dev/yalt

+## 3.0.0-beta.2
+
 ## 3.0.0-beta.1

 ## 3.0.0-beta.0
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/yalt",
-  "version": "3.0.0-beta.1",
+  "version": "3.0.0-beta.2",
  "description": "yalt.dev client library",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -809,10 +809,10 @@ importers:
  integrations/airtable:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      airtable:
        specifier: ^0.12.1
@@ -852,10 +852,10 @@ importers:
        specifier: ^12.0.10
        version: 12.0.10
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      octokit:
        specifier: ^3.1.2
@@ -895,10 +895,10 @@ importers:
        specifier: ^8.0.0
        version: 8.0.0
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      zod:
        specifier: 3.22.3
@@ -926,10 +926,10 @@ importers:
  integrations/openai:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      openai:
        specifier: ^4.16.1
@@ -969,10 +969,10 @@ importers:
        specifier: ^2.7.0
        version: 2.7.0
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
    devDependencies:
      '@trigger.dev/tsconfig':
@@ -997,10 +997,10 @@ importers:
  integrations/replicate:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      replicate:
        specifier: ^0.18.1
@@ -1031,10 +1031,10 @@ importers:
  integrations/resend:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      resend:
        specifier: ^2.1.0
@@ -1065,10 +1065,10 @@ importers:
        specifier: ^7.7.0
        version: 7.7.0
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
    devDependencies:
      '@trigger.dev/tsconfig':
@@ -1096,10 +1096,10 @@ importers:
        specifier: ^8.0.2
        version: 8.0.2
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      zod:
        specifier: 3.22.3
@@ -1130,7 +1130,7 @@ importers:
        specifier: ^6.8.1
        version: 6.8.1
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      zod:
        specifier: 3.22.3
@@ -1158,10 +1158,10 @@ importers:
  integrations/stripe:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      stripe:
        specifier: ^12.14.0
@@ -1195,10 +1195,10 @@ importers:
        specifier: ^2.26.0
        version: 2.31.0
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      supabase-management-js:
        specifier: ^1.0.0
@@ -1229,10 +1229,10 @@ importers:
  integrations/typeform:
    dependencies:
      '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/integration-kit
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../../packages/trigger-sdk
      '@typeform/api-client':
        specifier: ^1.8.0
@@ -1260,7 +1260,7 @@ importers:
  packages/astro:
    dependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      debug:
        specifier: ^4.3.4
@@ -1475,7 +1475,7 @@ importers:
        specifier: ^1.22.0
        version: 1.22.0
      '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../core
      '@types/degit':
        specifier: ^2.8.3
@@ -1923,7 +1923,7 @@ importers:
        version: 4.18.2
    devDependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      '@trigger.dev/tsconfig':
        specifier: workspace:*
@@ -2018,7 +2018,7 @@ importers:
        version: 4.3.4(supports-color@8.1.1)
    devDependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      '@trigger.dev/tsconfig':
        specifier: workspace:*
@@ -2051,7 +2051,7 @@ importers:
  packages/nextjs:
    dependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      debug:
        specifier: ^4.3.4
@@ -2137,7 +2137,7 @@ importers:
        specifier: 5.0.0-beta.2
        version: 5.0.0-beta.2(react@18.2.0)
      '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../core
      debug:
        specifier: ^4.3.4
@@ -2180,7 +2180,7 @@ importers:
  packages/remix:
    dependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      debug:
        specifier: ^4.3.4
@@ -2217,7 +2217,7 @@ importers:
  packages/sveltekit:
    dependencies:
      '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../trigger-sdk
      debug:
        specifier: ^4.3.4
@@ -2291,10 +2291,10 @@ importers:
        specifier: ^1.22.0
        version: 1.22.0
      '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../core
      '@trigger.dev/core-backend':
-        specifier: workspace:^3.0.0-beta.1
+        specifier: workspace:^3.0.0-beta.2
        version: link:../core-backend
      chalk:
        specifier: ^5.2.0
@@ -17,9 +17,7 @@ export const superParentTask = task({
    logger.log(`typeof result.error = ${typeof result.error}`);
    logger.log(`typeof result.url = ${typeof result.url}`);

-    return {
-      result,
-    };
+    return "## super-parent-task completed";
  },
 });

@@ -120,6 +118,35 @@ export const superHugeOutputTask = task({
  },
 });

+export const superStringTask = task({
+  id: "super-string-parent-task",
+  run: async () => {
+    const result = await superStringChildTask.triggerAndWait({
+      payload: {
+        foo: "bar",
+      },
+    });
+
+    return result;
+  },
+});
+
+export const superStringChildTask = task({
+  id: "super-string-child-task",
+  run: async () => {
+    return "## super-string-child-task completed";
+  },
+});
+
+export const superBadOutputTask = task({
+  id: "super-bad-output-task",
+  run: async () => {
+    // Returning something that cannot be serialized
+
+    return () => {};
+  },
+});
+
 function createLargeObject(size: number, length: number) {
  return Array.from({ length }, (_, i) => [i.toString(), i.toString().padStart(size, "0")]).reduce(
    (acc, [key, value]) => {
Author	SHA1	Message	Date
Eric Allam	6f9f25481e	Update pnpm lock file	2024-03-28 19:55:14 +00:00
github-actions[bot]	67aaffb6fc	chore: Update version for release (beta) (#984 ) Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>	2024-03-28 19:54:21 +00:00
Eric Allam	e3cf456c69	v3: fix string and non-standard outputs (#983 ) * Fixed string outputs missing and incorrectly formatted * Handle non-serializable outputs like a function * Add changeset	2024-03-28 19:51:29 +00:00
Matt Aitken	bf7827e7b8	Fix for the test latest runs showing other environments	2024-03-28 18:14:47 +00:00
Eric Allam	bc020a3ffe	Get the internal telemetry ready for test/prod	2024-03-28 18:12:01 +00:00