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,