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 5cd9657696 fix fmt
5cd9657696 is described below

commit 5cd9657696aa6a3482fbbdfb3196c56495cd8b23
Author: Xinyuan Lin <[email protected]>
AuthorDate: Sun Apr 19 16:00:06 2026 -0700

    fix fmt
---
 amber/src/main/python/core/runnables/main_loop.py | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/amber/src/main/python/core/runnables/main_loop.py 
b/amber/src/main/python/core/runnables/main_loop.py
index 844ce95f65..d73c655734 100644
--- a/amber/src/main/python/core/runnables/main_loop.py
+++ b/amber/src/main/python/core/runnables/main_loop.py
@@ -38,15 +38,8 @@ from core.models.internal_queue import (
     ECMElement,
     InternalQueueElement,
 )
-from core.models.operator import LoopEndOperator, LoopStartOperator
-from core.models.state import (
-    State,
-    STATE_SCHEMA,
-    serialize_state,
-    state_uri_from_result_uri,
-)
+from core.models.state import State
 from core.runnables.data_processor import DataProcessor
-from core.storage.document_factory import DocumentFactory
 from core.util import StoppableQueueBlockingRunnable, get_one_of
 from core.util.console_message.timestamp import current_time_in_local_timezone
 from core.util.customized_queue.queue_base import QueueElement
@@ -55,7 +48,6 @@ from proto.org.apache.texera.amber.core import (
     PortIdentity,
     ChannelIdentity,
     EmbeddedControlMessageIdentity,
-    OperatorIdentity,
 )
 from proto.org.apache.texera.amber.engine.architecture.rpc import (
     ConsoleMessage,

Reply via email to