From 31c1cafb2a2debfe1031dac927b699992df163b0 Mon Sep 17 00:00:00 2001
From: Joe Clark <jclark@openfn.org>
Date: Wed, 10 Sep 2025 10:16:58 +0100
Subject: [PATCH] log tweaking

---
 packages/ws-worker/src/channels/run.ts | 5 ++---
 packages/ws-worker/src/server.ts       | 2 +-
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/packages/ws-worker/src/channels/run.ts b/packages/ws-worker/src/channels/run.ts
index 315d1adef..811ff40f1 100644
--- a/packages/ws-worker/src/channels/run.ts
+++ b/packages/ws-worker/src/channels/run.ts
@@ -60,11 +60,10 @@ const joinRunChannel = (
       // channel was explicitly closed by the client or server
       logger.debug(`Leaving ${channelName}`);
     });
-    channel.onError((e: any) => {
+    channel.onError((...args: any) => {
       // Error occurred on the channel
       // (the socket will try to reconnect with backoff)
-      logger.debug(`Error in ${channelName}`);
-      logger.debug(e);
+      logger.debug(`Critical error in channel ${channelName}`, args);
     });
   });
 };
diff --git a/packages/ws-worker/src/server.ts b/packages/ws-worker/src/server.ts
index d7fa9db14..9e2db6217 100644
--- a/packages/ws-worker/src/server.ts
+++ b/packages/ws-worker/src/server.ts
@@ -273,7 +273,7 @@ function createServer(engine: RuntimeEngine, options: ServerOptions = {}) {
           collectionsVersion: app.options.collectionsVersion,
           monorepoPath: app.options.monorepoDir,
         });
-        logger.debug('converted run body into execution plan:', plan);
+        //logger.debug('converted run body into execution plan:', plan);
 
         // Setup collections
         if (plan.workflow.credentials?.collections_token) {