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