(texera) branch fix/do-not-truncate-debug-messages created (now 274978bef9)

[yi...@apache.org]

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

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


      at 274978bef9 fix: do not truncate debug messages

This branch includes the following new commits:

     new 274978bef9 fix: do not truncate debug messages

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(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)
   }