This is an automated email from the ASF dual-hosted git repository. aglinxinyuan pushed a commit to branch xinyuan-fix-state-processing in repository https://gitbox.apache.org/repos/asf/texera.git
commit f5dab86385b8888e8125063fba142ef9fbabcd34 Author: Xinyuan Lin <[email protected]> AuthorDate: Mon Apr 20 02:36:50 2026 -0700 init --- amber/src/main/python/core/runnables/data_processor.py | 1 + amber/src/main/python/core/runnables/main_loop.py | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/amber/src/main/python/core/runnables/data_processor.py b/amber/src/main/python/core/runnables/data_processor.py index 4399b1a3a2..815e85a644 100644 --- a/amber/src/main/python/core/runnables/data_processor.py +++ b/amber/src/main/python/core/runnables/data_processor.py @@ -100,6 +100,7 @@ class DataProcessor(Runnable, Stoppable): self._context.worker_id, self._context.console_message_manager.print_buf, ): + self._switch_context() self._set_output_state(executor.process_state(state, port_id)) except Exception as err: diff --git a/amber/src/main/python/core/runnables/main_loop.py b/amber/src/main/python/core/runnables/main_loop.py index d73c655734..2f2391cf7b 100644 --- a/amber/src/main/python/core/runnables/main_loop.py +++ b/amber/src/main/python/core/runnables/main_loop.py @@ -241,6 +241,7 @@ class MainLoop(StoppableQueueBlockingRunnable): def _process_state(self, state_: State) -> None: self.context.state_processing_manager.current_input_state = state_ + self._switch_context() self.process_input_state() self._check_and_process_control() @@ -329,7 +330,7 @@ class MainLoop(StoppableQueueBlockingRunnable): if ecm.ecm_type != EmbeddedControlMessageType.NO_ALIGNMENT: self.context.pause_manager.resume(PauseType.ECM_PAUSE) - + self._switch_context() if self.context.tuple_processing_manager.current_internal_marker: { StartChannel: self._process_start_channel,
