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