disable run debug logs for supervisor client

Author: nicktrn

apps/supervisor/src/index.ts

@@ -130,6 +130,7 @@ class ManagedSupervisor {
       maxConsumerCount: env.TRIGGER_DEQUEUE_MAX_CONSUMER_COUNT,
       runNotificationsEnabled: env.TRIGGER_WORKLOAD_API_ENABLED,
       heartbeatIntervalSeconds: env.TRIGGER_WORKER_HEARTBEAT_INTERVAL_SECONDS,
+      sendRunDebugLogs: env.SEND_RUN_DEBUG_LOGS,
       preDequeue: async () => {
         if (!env.RESOURCE_MONITOR_ENABLED) {
           return {};

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

@@ -33,6 +33,7 @@ export class SupervisorHttpClient {
   private readonly workerToken: string;
   private readonly instanceName: string;
   private readonly defaultHeaders: Record<string, string>;
+  private readonly sendRunDebugLogs: boolean;
 
   private readonly logger = new SimpleStructuredLogger("supervisor-http-client");
 
@@ -41,6 +42,7 @@ export class SupervisorHttpClient {
     this.workerToken = opts.workerToken;
     this.instanceName = opts.instanceName;
     this.defaultHeaders = getDefaultWorkerHeaders(opts);
+    this.sendRunDebugLogs = opts.sendRunDebugLogs ?? false;
 
     if (!this.apiUrl) {
       throw new Error("apiURL is required and needs to be a non-empty string");
@@ -204,6 +206,10 @@ export class SupervisorHttpClient {
   }
 
   async sendDebugLog(runId: string, body: WorkerApiDebugLogBody, runnerId?: string): Promise<void> {
+    if (!this.sendRunDebugLogs) {
+      return;
+    }
+
     try {
       const res = await wrapZodFetch(
         z.unknown(),

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

@@ -21,6 +21,7 @@ type SupervisorSessionOptions = SupervisorClientCommonOptions & {
   preSkip?: PreSkipFn;
   maxRunCount?: number;
   maxConsumerCount?: number;
+  sendRunDebugLogs?: boolean;
 };
 
 export class SupervisorSession extends EventEmitter<WorkerEvents> {

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

@@ -6,6 +6,7 @@ export type SupervisorClientCommonOptions = {
   instanceName: string;
   deploymentId?: string;
   managedWorkerSecret?: string;
+  sendRunDebugLogs?: boolean;
 };
 
 export type PreDequeueFn = () => Promise<{