aglinxinyuan commented on code in PR #4488:
URL: https://github.com/apache/texera/pull/4488#discussion_r3165147560
##########
amber/src/main/python/core/runnables/network_receiver.py:
##########
@@ -96,7 +97,17 @@ def data_handler(command: bytes, table: Table) -> int:
"Data",
lambda _: DataFrame(table),
"State",
- lambda _: StateFrame(State(table)),
+ lambda _: StateFrame(
+ deserialize_state(
+ Tuple(
+ {
+ name: table[name][0].as_py()
Review Comment:
For network transport, each State message is intentionally one serialized
state row. Multiple states are sent as multiple State messages, not as multiple
rows in one network payload. I made that explicit by factoring the logic into
_deserialize_state_payload(...), adding assert len(table) == 1, and adding a
Python test that sends two consecutive state messages and verifies both are
received.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
