(texera) branch xinyuan-loop-feb updated: fix fmt

[linxinyuan]

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

aglinxinyuan pushed a commit to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-loop-feb by this push:
     new 7172471a8d fix fmt
7172471a8d is described below

commit 7172471a8de1eb445719b06914bf59f40c4c1b47
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Sat Apr 18 17:49:59 2026 -0700

    fix fmt
---
 .../src/main/scala/org/apache/texera/amber/core/state/State.scala     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/State.scala
 
b/common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/State.scala
index e0af039eb9..9e9eb1fce7 100644
--- 
a/common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/State.scala
+++ 
b/common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/State.scala
@@ -40,12 +40,12 @@ object State {
   def stateUriFromResultUri(resultUri: URI): URI =
     new URI(resultUri.toString.replace("/result", "/state"))
 
-  def serialize(state: Map[String, Any]): Tuple = {
+  def serialize(state: State): Tuple = {
     val payloadJson = objectMapper.writeValueAsString(toJsonValue(state))
     Tuple.builder(schema).addSequentially(Array(payloadJson)).build()
   }
 
-  def deserialize(tuple: Tuple): Map[String, Any] = {
+  def deserialize(tuple: Tuple): State = {
     val payload = tuple.getField[String](StateContent)
     objectMapper.readTree(payload).fields().asScala.map(entry => entry.getKey 
-> fromJsonValue(entry.getValue)).toMap
   }