managed run logger accepts nested props

Author: nicktrn

packages/cli-v3/src/entryPoints/managed/logger.ts

@@ -1,14 +1,16 @@
 import {
+  DebugLogPropertiesInput,
   WorkloadDebugLogRequestBody,
   WorkloadHttpClient,
 } from "@trigger.dev/core/v3/runEngineWorker";
 import { RunnerEnv } from "./env.js";
+import { flattenAttributes } from "@trigger.dev/core/v3";
 
 export type SendDebugLogOptions = {
   runId?: string;
   message: string;
   date?: Date;
-  properties?: WorkloadDebugLogRequestBody["properties"];
+  properties?: DebugLogPropertiesInput;
   print?: boolean;
 };
 
@@ -46,10 +48,14 @@ export class RunLogger {
       console.log(message, mergedProperties);
     }
 
+    const flattenedProperties = flattenAttributes(
+      mergedProperties
+    ) satisfies WorkloadDebugLogRequestBody["properties"];
+
     this.httpClient.sendDebugLog(runId, {
       message,
       time: date ?? new Date(),
-      properties: mergedProperties,
+      properties: flattenedProperties,
     });
   }
 }

packages/core/src/v3/runEngineWorker/supervisor/schemas.ts

@@ -130,14 +130,24 @@ export const DebugLogPropertiesValue = z.union([
   z.string(),
   z.number(),
   z.boolean(),
-  z.array(z.string().nullable()),
-  z.array(z.number().nullable()),
-  z.array(z.boolean().nullable()),
+  z.array(z.string().nullish()),
+  z.array(z.number().nullish()),
+  z.array(z.boolean().nullish()),
 ]);
 
 export const DebugLogProperties = z.record(z.string(), DebugLogPropertiesValue.optional());
 export type DebugLogProperties = z.infer<typeof DebugLogProperties>;
 
+export const DebugLogPropertiesInput = z.record(z.string(), z.unknown());
+export type DebugLogPropertiesInput = z.infer<typeof DebugLogPropertiesInput>;
+
+export const WorkerApiDebugLogBodyInput = z.object({
+  time: z.coerce.date(),
+  message: z.string(),
+  properties: DebugLogPropertiesInput.optional(),
+});
+export type WorkerApiDebugLogBodyInput = z.infer<typeof WorkerApiDebugLogBodyInput>;
+
 export const WorkerApiDebugLogBody = z.object({
   time: z.coerce.date(),
   message: z.string(),

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

@@ -18,7 +18,7 @@ import {
   WaitReason,
 } from "./schemas.js";
 import { CompletedWaitpoint } from "./runEngine.js";
-import { DebugLogProperties } from "../runEngineWorker/index.js";
+import { DebugLogPropertiesInput } from "../runEngineWorker/index.js";
 
 export const AckCallbackResult = z.discriminatedUnion("success", [
   z.object({
@@ -179,7 +179,7 @@ export const ExecutorToWorkerMessageCatalog = {
     message: z.object({
       version: z.literal("v1").default("v1"),
       message: z.string(),
-      properties: DebugLogProperties.optional(),
+      properties: DebugLogPropertiesInput.optional(),
     }),
   },
 };