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 <[email protected]> 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) }
