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


The following commit(s) were added to refs/heads/xinyuan-state-only by this 
push:
     new 345fa41c78 fix fmt
345fa41c78 is described below

commit 345fa41c782a8c3eff4327b7c7d6a2ebcad6f34a
Author: Xinyuan Lin <[email protected]>
AuthorDate: Sun Apr 19 16:15:57 2026 -0700

    fix fmt
---
 .../amber/engine/architecture/pythonworker/PythonProxyClient.scala  | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyClient.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyClient.scala
index e53fccf8c0..cfdb6a82f8 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyClient.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/pythonworker/PythonProxyClient.scala
@@ -126,11 +126,7 @@ class PythonProxyClient(portNumberPromise: Promise[Int], 
val actorId: ActorVirtu
       case DataFrame(frame) =>
         writeArrowStream(mutable.Queue(ArraySeq.unsafeWrapArray(frame): _*), 
from, "Data")
       case StateFrame(state) =>
-        writeArrowStream(
-          mutable.Queue(State.serialize(state)),
-          from,
-          "State"
-        )
+        writeArrowStream(mutable.Queue(State.serialize(state)), from, "State")
     }
   }
 

Reply via email to