This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-state-materialization
in repository https://gitbox.apache.org/repos/asf/texera.git
from 4223cf5640 refactor(storage): make port URIs symmetric over a base URI
add 34b004d012 fix(amber): surface writer-thread failure as FatalError
instead of silent hang (#4683)
add 933f7fed77 test(frontend): unblock 7 specs from jsdom (#4950)
add 2d6a759a90 refactor(pyamber): flatten over-nested util packages (#4952)
add f36b938892 chore(deps-dev): bump webpack from 5.89.0 to 5.104.1 in
/frontend (#4970)
add 3bb05ab3fa chore(ci): show Codecov carryforward flags in PR comments
(#4973)
add 9fc5b39d96 test(amber): add unit test coverage for NetworkOutputBuffer
(#4958)
add d3bb7662f4 Merge branch 'main' into xinyuan-state-materialization
No new revisions were added by this update.
Summary of changes:
amber/src/main/python/core/python_worker.py | 4 +-
.../main/python/core/runnables/data_processor.py | 2 +-
amber/src/main/python/core/runnables/heartbeat.py | 4 +-
.../main/python/core/runnables/network_receiver.py | 2 +-
.../input_port_materialization_reader_runnable.py | 2 +-
.../main/python/core/util/{thread => }/atomic.py | 0
.../core/util/{protocol => }/base_protocols.py | 0
.../main/python/core/util/buffer/buffer_base.py | 2 +-
.../linked_blocking_multi_queue.py | 2 +-
.../core/util/customized_queue/queue_base.py | 2 +-
.../__init__.py => expression_evaluator.py} | 0
.../src/main/python/core/util/operator/__init__.py | 16 --
.../python/core/util/{runnable => }/runnable.py | 0
.../stoppable/stoppable_queue_blocking_thread.py | 4 +-
amber/src/main/python/core/util/thread/__init__.py | 16 --
.../__init__.py => virtual_identity.py} | 0
.../messaginglayer/OutputManager.scala | 6 +
.../managers/OutputPortResultWriterThread.scala | 38 ++-
amber/src/test/python/core/test_python_worker.py | 125 ++++++++++
.../python/core/util/{thread => }/test_atomic.py | 2 +-
.../test_expression_evaluator.py | 0
.../test_virtual_identity.py | 0
.../partitioners/NetworkOutputBufferSpec.scala | 274 +++++++++++++++++++++
.../OutputPortResultWriterThreadSpec.scala | 151 ++++++++++++
codecov.yml | 9 +
frontend/angular.json | 7 -
frontend/package.json | 4 +-
.../code-debugger.component.spec.ts | 11 +-
.../code-editor.component.spec.ts | 11 +-
.../codearea-custom-template.component.spec.ts | 11 +-
.../time-travel/time-travel.component.spec.ts | 12 +-
.../versions-list/versions-list.component.spec.ts | 12 +-
.../operator-property-edit-frame.component.spec.ts | 15 +-
.../service/drag-drop/drag-drop.service.spec.ts | 10 +-
frontend/src/jsdom-svg-polyfill.ts | 19 ++
frontend/src/tsconfig.spec.json | 23 +-
frontend/vitest.config.ts | 11 +
frontend/yarn.lock | 105 ++++----
38 files changed, 745 insertions(+), 167 deletions(-)
rename amber/src/main/python/core/util/{thread => }/atomic.py (100%)
rename amber/src/main/python/core/util/{protocol => }/base_protocols.py (100%)
rename amber/src/main/python/core/util/{expression_evaluator/__init__.py =>
expression_evaluator.py} (100%)
delete mode 100644 amber/src/main/python/core/util/operator/__init__.py
rename amber/src/main/python/core/util/{runnable => }/runnable.py (100%)
delete mode 100644 amber/src/main/python/core/util/thread/__init__.py
rename amber/src/main/python/core/util/{virtual_identity/__init__.py =>
virtual_identity.py} (100%)
create mode 100644 amber/src/test/python/core/test_python_worker.py
rename amber/src/test/python/core/util/{thread => }/test_atomic.py (99%)
rename amber/src/test/python/core/util/{expression_evaluator =>
}/test_expression_evaluator.py (100%)
rename amber/src/test/python/core/util/{virtual_identity =>
}/test_virtual_identity.py (100%)
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/sendsemantics/partitioners/NetworkOutputBufferSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/managers/OutputPortResultWriterThreadSpec.scala
