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) {