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

linxinyuan 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 19be0c1a3b update
19be0c1a3b is described below

commit 19be0c1a3b4282f6c1830b254de6b78a6f2c705e
Author: Xinyuan Lin <[email protected]>
AuthorDate: Tue Feb 10 19:28:06 2026 -0800

    update
---
 .../engine/architecture/worker/promisehandlers/AssignPortHandler.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
index 57a7782cf5..fe959733ab 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
@@ -55,7 +55,7 @@ trait AssignPortHandler {
         // Same as AddInputChannelHandler
         dp.inputGateway.getChannel(channelId).setPortId(msg.portId)
         dp.inputManager.getPort(msg.portId).channels.add(channelId)
-        //dp.stateManager.assertState(READY, RUNNING, PAUSED)
+        dp.stateManager.assertState(READY, RUNNING, PAUSED)
       }
     } else {
       val storageURIOption: Option[URI] = msg.storageUris.head match {

Reply via email to