This is an automated email from the ASF dual-hosted git repository. aglinxinyuan pushed a commit to branch xinyuan-state-only in repository https://gitbox.apache.org/repos/asf/texera.git
commit b6d14ee05d7507aaff148d0dd4c54461a37113d0 Author: Xinyuan Lin <[email protected]> AuthorDate: Sun Apr 19 16:16:23 2026 -0700 fix fmt --- .../amber/engine/architecture/pythonworker/PythonProxyServer.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyServer.scala b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyServer.scala index 2a1e212ac8..463dc4b75a 100644 --- a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyServer.scala +++ b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyServer.scala @@ -128,10 +128,7 @@ private class AmberProducer( dataHeader.payloadType match { case "State" => assert(root.getRowCount == 1) - outputPort.sendTo( - to, - StateFrame(State.deserialize(ArrowUtils.getTexeraTuple(0, root))) - ) + outputPort.sendTo(to, StateFrame(State.deserialize(ArrowUtils.getTexeraTuple(0, root)))) case "ECM" => assert(root.getRowCount == 1) outputPort.sendTo(
