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 b313e16f3c fix: update if operator state access
b313e16f3c is described below

commit b313e16f3cc7823b70b81016eb06a32c33e40951
Author: Xinyuan Lin <[email protected]>
AuthorDate: Sun Apr 19 01:32:41 2026 -0700

    fix: update if operator state access
---
 .../scala/org/apache/texera/amber/operator/ifStatement/IfOpExec.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/ifStatement/IfOpExec.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/ifStatement/IfOpExec.scala
index 462bdd0969..d2becc79a5 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/ifStatement/IfOpExec.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/ifStatement/IfOpExec.scala
@@ -34,7 +34,7 @@ class IfOpExec(descString: String) extends OperatorExecutor {
   //It can accept any value that can be converted to a boolean. For example, 
Int 1 will be converted to true.
   override def processState(state: State, port: Int): Option[State] = {
     outputPort =
-      if (state.get(desc.conditionName).asInstanceOf[Boolean]) PortIdentity(1) 
else PortIdentity()
+      if (state(desc.conditionName).asInstanceOf[Boolean]) PortIdentity(1) 
else PortIdentity()
     Some(state)
   }
 

Reply via email to