(texera) 01/01: fix: do not truncate debug messages

[yi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yiconghuang pushed a commit to branch fix/do-not-truncate-debug-messages
in repository https://gitbox.apache.org/repos/asf/texera.git

commit 274978bef901d69f54732ec9fbaf7aad307a5e69
Author: Yicong Huang <17...@users.noreply.github.com>
AuthorDate: Tue Sep 30 10:59:58 2025 -0400

    fix: do not truncate debug messages
---
 .../web/service/ExecutionConsoleService.scala      | 27 +++++++---------------
 1 file changed, 8 insertions(+), 19 deletions(-)

diff --git a/core/amber/src/main/scala/edu/uci/ics/texera/web/service/ExecutionConsoleService.scala b/core/amber/src/main/scala/edu/uci/ics/texera/web/service/ExecutionConsoleService.scala
index ca4bede2c6..7de79de16c 100644
--- a/core/amber/src/main/scala/edu/uci/ics/texera/web/service/ExecutionConsoleService.scala
+++ b/core/amber/src/main/scala/edu/uci/ics/texera/web/service/ExecutionConsoleService.scala
@@ -24,26 +24,15 @@ import com.twitter.util.{Await, Duration}
 import com.typesafe.scalalogging.LazyLogging
 import edu.uci.ics.amber.config.ApplicationConfig
 import edu.uci.ics.amber.engine.architecture.rpc.controlcommands.ConsoleMessageType.COMMAND
-import edu.uci.ics.amber.engine.architecture.rpc.controlcommands.{
-  ConsoleMessage,
-  EvaluatePythonExpressionRequest,
-  DebugCommandRequest => AmberDebugCommandRequest
-}
+import edu.uci.ics.amber.engine.architecture.rpc.controlcommands.{ConsoleMessage, ConsoleMessageType, EvaluatePythonExpressionRequest, DebugCommandRequest => AmberDebugCommandRequest}
 import edu.uci.ics.amber.engine.common.client.AmberClient
-import edu.uci.ics.amber.engine.common.executionruntimestate.{
-  EvaluatedValueList,
-  ExecutionConsoleStore,
-  OperatorConsole
-}
+import edu.uci.ics.amber.engine.common.executionruntimestate.{EvaluatedValueList, ExecutionConsoleStore, OperatorConsole}
 import edu.uci.ics.amber.util.VirtualIdentityUtils
 import edu.uci.ics.amber.core.virtualidentity.{ActorVirtualIdentity, OperatorIdentity}
 import edu.uci.ics.texera.web.model.websocket.event.TexeraWebSocketEvent
 import edu.uci.ics.texera.web.model.websocket.event.python.ConsoleUpdateEvent
 import edu.uci.ics.texera.web.model.websocket.request.RetryRequest
-import edu.uci.ics.texera.web.model.websocket.request.python.{
-  DebugCommandRequest,
-  PythonExpressionEvaluateRequest
-}
+import edu.uci.ics.texera.web.model.websocket.request.python.{DebugCommandRequest, PythonExpressionEvaluateRequest}
 import edu.uci.ics.texera.web.model.websocket.response.python.PythonExpressionEvaluateResponse
 import edu.uci.ics.texera.web.storage.ExecutionStateStore
 import edu.uci.ics.texera.web.{SubscriptionManager, WebsocketInput}
@@ -54,11 +43,7 @@ import edu.uci.ics.amber.core.tuple.Tuple
 import edu.uci.ics.amber.core.workflow.WorkflowContext
 import edu.uci.ics.amber.engine.architecture.controller.ExecutionStateUpdate
 import edu.uci.ics.amber.engine.architecture.rpc.controlreturns.WorkflowAggregatedState
-import edu.uci.ics.amber.engine.architecture.rpc.controlreturns.WorkflowAggregatedState.{
-  COMPLETED,
-  FAILED,
-  KILLED
-}
+import edu.uci.ics.amber.engine.architecture.rpc.controlreturns.WorkflowAggregatedState.{COMPLETED, FAILED, KILLED}
 import edu.uci.ics.texera.config.UserSystemConfig
 import edu.uci.ics.texera.web.resource.dashboard.user.workflow.WorkflowExecutionsResource
 
@@ -225,6 +210,10 @@ class ExecutionConsoleService(
     * @return The truncated console message
     */
   def processConsoleMessage(consoleMessage: ConsoleMessage): ConsoleMessage = {
+    // Do not truncate debugger messages
+    if (consoleMessage.msgType== ConsoleMessageType.DEBUGGER){
+      return consoleMessage
+    }
     ConsoleMessageProcessor.processConsoleMessage(consoleMessage, consoleMessageDisplayLength)
   }