This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-remove-root-dockerfile
in repository https://gitbox.apache.org/repos/asf/texera.git
from 755a0d01be Merge branch 'main' into xinyuan-remove-root-dockerfile
add d3d17b0b0d chore(asf): require conversation resolution before merge
(#4660)
add 69f3aea33a fix(ci): generate the coverage files Codecov uploads expect
(#4649)
add 9a8214dc7a test(pyamber): cover sendsemantics partitioners (#4664)
add 1780287a6f fix(ci): wire CODECOV_TOKEN to coverage uploads (Phase 2 of
#4645) (#4666)
add 71812eb2bb test(amber): add unit test coverage for Schedule iterator
semantics (#4562)
add 8841990f1d ci: add temporary AutoQueue workflow as merge-queue
stand-in (#4672)
add 34a00cc395 docs(scala): fully-qualify ScalaDoc @throws and link
references (#4671)
add 254faf8eac fix(ci): drop strict BEHIND filter in AutoQueue, iterate
candidates (#4678)
add de64d70639 fix(ci): include litellm-config.yaml in RC docker-compose
bundle (#4652)
add cfe472e9c9 chore(licensing): per-module LICENSE/NOTICE binaries with
per-image concat (#4668)
add 7811115ade ci: push backports with AUTO_MERGE_TOKEN to retrigger
release-branch CI (#4676)
add 598ed0f7f0 test(amber): drop stale Thread.sleep(1000) after COMPLETED
state (#4680)
add b98c863127 chore(licensing): add --ignore-transitive-version flag and
use it on PR builds (#4693)
add 6cf43225a5 refactor(ci): split scala job into amber + platform matrix
(#4632)
add e3d96b0d83 chore(ci): upgrade actions to Node.js 24 runtimes (#4648)
add 6b7e8cf7ce test(pyamber): add unit tests for DatasetFileDocument
(#4702)
add 6ed78dd49b chore(ci): add codecov.yml — carryforward, ignore
generated/test paths, loosen status checks (#4690)
add 09715e1c46 docs: add Codecov coverage badge to README (#4714)
add a5b895715e fix(ci): place "(backported from commit X)" before trailers
in backport message (#4696)
add 01f6803f06 test(agent-service): add unit tests for result-formatting
(#4695)
add 7fc73d1274 test(agent-service): add unit tests for auto-layout (#4700)
add bd4f019664 test(agent-service): add unit tests for tools-utility
(#4698)
add 84180b7cab test(amber): add unit tests for VirtualIdentityUtils (#4712)
add 0c5681989f test(pyamber): add unit tests for Heartbeat (#4704)
add 88c7a21ea1 test(amber): add unit tests for OrderingEnforcer (#4721)
add 945849ce4f test(amber): add unit tests for deploy strategies (#4723)
add 8cf5b9a7f1 test(amber): add unit test coverage for DataFrame equality
and inMemSize (#4784)
add 5a5ee19541 test(amber): add unit tests for ErrorUtils (#4709)
add 798219386f chore(deps): upgrade frontend Node engine to 24 (#4658)
add f1be42897b test(amber): add unit test coverage for
ProcessingStepCursor (#4764)
add 540785920d docs: rewrite AGENTS.md as agent-facing index (#4825)
add ecc2fabdb5 test(amber): add unit tests for JSONUtils (#4716)
add e99577bcb2 test(pyamber): add unit tests for update_executor logic
(#4719)
add 1c3ec67977 test(pyamber): add unit tests for Operator base class
(#4735)
add b8c1abba42 fix(ci): expand Auto Queue triggers and skip when queue
head is in flight (#4845)
add 2812cad659 test(amber): add unit test coverage for WorkerStateManager
(#4740)
add fc83951058 test(amber): add unit test coverage for StateManager (#4738)
add af5d174a8e fix(ci): repair direct-backport-push YAML and post backport
result comments (#4846)
add cb2f375bb9 test(workflow-core): add unit test coverage for
VFSURIFactory (#4757)
add 9bcbbc062f test(amber): add unit tests for ArrowUtils (#4758)
add 5a80494f7d test(amber): add unit test coverage for WorkerPortExecution
(#4772)
add 9ece88e1a6 fix(licensing): preserve all versions in check_binary_deps
multi-version diff (#4711)
add 6485b0434c feat(ci): give Auto Queue an `emergency` label fast-path
(#4849)
add 7b6ed23adb test(amber): add unit test coverage for
EmptyReplayLogManagerImpl (#4790)
add 4f016f6f31 test(pyamber): add unit tests for AsyncRPCClient (#4744)
add 43b698cb70 test(amber): add unit test coverage for engine common Utils
(#4743)
add f46335deba test(workflow-operator): add unit test coverage for
MapOpExec (#4778)
add 7dc68ba642 ci: add a strict license-binary checker that files a
tracking issue on license drift (#4734)
add 3d80393330 fix(release): ship LICENSE/NOTICE/DISCLAIMER in
docker-compose tarball (#4850)
add d9fc9dca86 refactor(release): drop helm chart from RC artifacts (#4853)
add 37d134188f chore(licensing): bump tifffile to 2026.5.2 in
LICENSE-binary-python (#4855)
add 31adc70ef9 ci(release): gate RC creation on strict-mode build of the
tagged commit (#4857)
add 1c2a8c533f test(amber): add unit test coverage for non-range
partitioners (#4746)
add 6c24525173 chore(deps): bump protobuf to 7.34.1 (#4609)
add c7457f7e63 test(amber): add unit test coverage for CongestionControl
(#4748)
add f4c352d88e test(amber): add unit test coverage for FlowControl (#4750)
add 7e2163f56e test(amber): add unit test coverage for LinkExecution
(#4753)
add 99b0963b47 test(workflow-core): add unit test coverage for
PartitionInfo (#4755)
add b6f682c2a0 test(workflow-core): add unit test coverage for StorageUtil
(#4761)
add 655990f85b test(amber): add unit test coverage for GlobalReplayManager
(#4766)
add 21cf0fc380 test(amber): add unit test coverage for WorkerExecution
(#4768)
add 32e0c619f4 test(amber): add unit test coverage for RegionPlan (#4770)
add bbc50e21d7 test(workflow-operator): add unit test coverage for
LimitOpExec (#4774)
add 02ddb192cd test(workflow-operator): add unit test coverage for
FlatMapOpExec (#4776)
add 9e8ddfcc43 test(workflow-operator): add unit test coverage for
IfOpExec (#4781)
add d65745b8fa test(pyamber): add unit tests for customized_queue
inner-class decorators (#4782)
add ca11939481 test(workflow-operator): cover AVERAGE/MIN/MAX and
null-aggFunction in AggregateOpSpec (#4788)
add 5ecf746ff1 test(workflow-core): add unit test coverage for
FinalizePort and FinalizeExecutor markers (#4792)
add ced34484ca test(pyamber): add unit tests for replace_print and
AtomicInteger (#4795)
add e551e1b54b test(pyamber): add unit tests for virtual_identity
utilities (#4797)
add 6ae0c46312 fix(pyamber): make ExecutorManager module names
process-globally unique (#4717)
add f624949ece test(amber): add unit tests for
ChannelConfig.generateChannelConfigs (#4800)
add a505475741 test(amber): add unit tests for LinkConfig.toPartitioning
(#4803)
add 9b2005d5b6 test(amber): add unit tests for visualization OpDescs
(Image, FunnelPlot, VolcanoPlot, BulletChart) (#4809)
add f0e17c27d7 test(amber): add unit tests for visualization OpDescs
(HeatMap, BarChart, LineChart, PieChart) (#4812)
add a3d43db09a fix(ci): use uv for python deps, keep pip on 3.12
license-check leg (#4636)
add 0de0ec22b9 chore(frontend): move `--code-coverage` from build.yml into
test:ci script (#4869)
add 5cf0e7b751 test(amber): add unit tests for SleepOpDesc,
IntersectOpDesc, URLFetcherOpDesc (#4816)
add f33baafd1a test(amber): add unit test coverage for scheduling configs
(#4821)
add 455d671138 feat(frontend): migrate test runner Karma → Vitest (#4862)
add 1c895ccba5 test(amber): add unit test coverage for resourcePolicies
(#4824)
add 0d8cf3c05a test(amber): add unit test coverage for AmberMessage
envelopes (#4829)
add 6d617b612c test(amber): add unit test coverage for AmberFIFOChannel
and WorkerPort (#4831)
add 316a9c2d76 test(workflow-core): add unit test coverage for
core/executor reflection (#4834)
add cc37ee7f99 test(amber): add unit test coverage for worker managers
(Statistics/Serialization/Pause) (#4836)
add cee408b755 test(amber): add unit test coverage for checkpoint
subsystem (#4838)
add e448db30a0 test(workflow-core): add unit test coverage for workflow
core types (#4842)
add fdffddab76 feat(ci): split amber tests into amber + amber-integration
jobs (#4871)
add 9223ddf519 test(pyamber): add unit tests for _QueueReader and
cleanup-failed-upload paths (#4707)
add 3dd556a61c refactor(frontend): convert all components to standalone
(#4873)
add 47ef2f5fdc test(amber): add CheckpointState unknown-key negative test
(#4687)
add 33ea60e463 chore(frontend): re-enable spec files that pass under
standalone migration (#4878)
add 1bf18e7416 fix: avoid O(N) memory allocation when displaying large
binary blobs in result panel (#4876)
add e7b1cb6e0f chore(frontend): install ProxyZone wrapper, re-enable 4
service specs (#4881)
add 7cd34b17d1 chore(frontend): re-enable 13 component/service specs after
standalone migration (#4886)
add b16d0db4d3 feat(ci): sync issue assignees from PR closing refs and
handle `/take` comments (#4885)
add a15d4ff062 refactor(auth): move USER_LAST_ACTIVE_TIME write out of
JwtAuthFilter (#4888)
add aedc6e253b fix(frontend): drop fixed height on about-page login card
(#4890)
add 9f0cfd7517 test(pyamber): add unit tests for six DP-thread state
managers (#4893)
add d14b43db4d test(frontend): re-enable 11 result-panel/workspace
component specs (#4889)
add 33533217bd test(frontend): cover about-page login visibility branches
(#4894)
add 332d4f4f8d fix(ci): preserve in-progress runs on release/* branches
(#4883)
add 786a920796 refactor(auth): align JWT claim parsing across
microservices and amber (#4896)
add 06831ff568 chore(frontend): re-enable 6 admin/left-panel component
specs (#4897)
add 4d6b96a715 chore(licensing): bump pytz to 2026.2 in
LICENSE-binary-python (#4906)
add 07d8311584 ci: drop the `triage` label, use `is:open no:assignee`
filter (#4899)
add 6da0a35966 chore: drop `labels: ["triage"]` from issue templates
(#4918)
add 1c6021c543 test(workflow-core): add unit test coverage for TupleUtils
(#4910)
add 810263c3ef test(amber): add unit test coverage for PauseType (#4914)
add ef0634def0 test(workflow-operator): pin Sklearn OpDesc registry
strings (#4827)
add 8b8a8149dc test(amber): add unit tests for workflow-core
PartitionInfo, WorkflowRuntimeException, WorkflowContext (#4806)
add a4b186b72f test(amber): add unit tests for AmberFIFOChannel and
CongestionControl (#4819)
add b562b55b72 test(amber): add unit test coverage for logreplay
primitives (#4840)
add 94ab9c7551 feat(ui): add configuration for compute tab on admin page
(#4922)
add 9960041825 test(workflow-operator): add unit test coverage for
AggregationOperation (#4908)
add 1872ca0a91 test(workflow-operator): add unit test coverage for
ProgressiveUtils (#4912)
add aa8966250a test(amber): add unit test coverage for AddressInfo (#4916)
add 6ad54c8a90 feat(frontend): added clipboard icon to dataset detail page
(#4928)
add 265e0f88c7 chore(license): trim DISCLAIMER to canonical ASF Incubator
template (#4927)
add ea6607e7e0 chore(docker): add ASF Incubator disclaimer to Dockerfiles
(#4925)
add c533305148 feat(ci): allow RC bundle to pin IMAGE_TAG to the git tag
(#4930)
add 056e39d0d9 fix: Adding Floor to idle_time (#4900)
add d50ebb0afa chore: Relocate boto3 to core requirements.txt (#4934)
add 48e7c26ed7 Merge branch 'main' into xinyuan-remove-root-dockerfile
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/ISSUE_TEMPLATE/bug-template.yaml | 1 -
.github/ISSUE_TEMPLATE/feature-template.yaml | 1 -
.github/ISSUE_TEMPLATE/task-template.yaml | 1 -
.github/labeler.yml | 55 +-
.github/release/vote-email-template.md | 2 -
.github/scripts/compose-backport-message.py | 56 +
.github/workflows/auto-assign.yml | 96 --
.github/workflows/auto-queue.yml | 335 ++++++
.../automatic-email-notif-on-ddl-change.yml | 2 +-
.github/workflows/build-and-push-images.yml | 28 +-
.github/workflows/build.yml | 355 ++++--
.github/workflows/check-header.yml | 2 +-
.github/workflows/create-release-candidate.yml | 116 +-
.github/workflows/direct-backport-push.yml | 410 ++++++-
.github/workflows/issue-triage.yml | 89 --
.github/workflows/license-binary-checker.yml | 176 +++
.github/workflows/lint-pr.yml | 2 +-
.github/workflows/pr-assignment.yml | 258 +++++
.github/workflows/required-checks.yml | 89 +-
.github/workflows/take-commands.yml | 85 ++
.licenserc.yaml | 8 +-
AGENTS.md | 360 +++---
DISCLAIMER | 6 -
README.md | 1 +
.../LICENSE-binary | 284 +++--
.../NOTICE-binary | 491 --------
access-control-service/build.sbt | 4 +-
.../texera/service/AccessControlService.scala | 7 +
.../activity/UserActivityEventListener.scala | 79 ++
.../service/AccessControlServiceRunSpec.scala | 49 +
.../activity/UserActivityEventListenerSpec.scala | 136 +++
.../LICENSE-binary | 117 +-
.../src/agent/tools/result-formatting.test.ts | 326 ++++++
.../src/agent/tools/tools-utility.test.ts | 142 +++
agent-service/src/agent/util/auto-layout.test.ts | 149 +++
LICENSE-binary => amber/LICENSE-binary-java | 544 +--------
.../LICENSE-binary-python | 259 +++--
NOTICE-binary => amber/NOTICE-binary | 386 -------
amber/build.sbt | 30 +-
amber/operator-requirements.txt | 1 -
amber/requirements.txt | 3 +-
.../control/test_update_executor_handler.py | 89 ++
.../core/architecture/managers/executor_manager.py | 34 +-
.../architecture/managers/statistics_manager.py | 29 +-
.../managers/test_console_message_manager.py | 83 ++
.../test_embedded_control_message_manager.py | 194 ++++
.../managers/test_exception_manager.py | 76 ++
.../architecture/managers/test_executor_manager.py | 171 ++-
.../managers/test_state_processing_manager.py | 59 +
.../managers/test_statistics_manager.py | 147 +++
.../managers/test_tuple_processing_manager.py | 100 ++
.../core/architecture/rpc/test_async_rpc_client.py | 259 +++++
.../sendsemantics/test_partitioners.py | 434 +++++++
amber/src/main/python/core/models/test_operator.py | 291 +++++
.../main/python/core/runnables/test_heartbeat.py | 117 ++
.../util/console_message/test_replace_print.py | 135 +++
.../core/util/customized_queue/test_inner.py | 182 +++
.../main/python/core/util/thread/test_atomic.py | 139 +++
.../util/virtual_identity/test_virtual_identity.py | 149 +++
.../pytexera/storage/large_binary_input_stream.py | 24 +-
.../pytexera/storage/large_binary_output_stream.py | 51 +-
.../pytexera/storage/test_dataset_file_document.py | 192 ++++
.../storage/test_large_binary_input_stream.py | 12 +-
.../storage/test_large_binary_output_stream.py | 127 ++-
.../controller/execution/OperatorExecution.scala | 2 +-
.../controller/execution/RegionExecution.scala | 4 +-
.../controller/execution/WorkflowExecution.scala | 4 +-
.../apache/texera/web/auth/UserAuthenticator.scala | 39 +-
.../web/resource/dashboard/hub/HubResource.scala | 2 +-
.../web/service/ExecutionResultService.scala | 53 +-
.../e2e/ReconfigurationIntegrationSpec.scala} | 160 +--
.../apache/texera/amber/tags/IntegrationTest.java | 52 +
.../common/ProcessingStepCursorSpec.scala | 66 ++
.../controller/GlobalReplayManagerSpec.scala | 104 ++
.../controller/execution/LinkExecutionSpec.scala | 66 ++
.../execution/WorkerPortExecutionSpec.scala} | 31 +-
.../deploysemantics/AddressInfoSpec.scala | 84 ++
.../deploystrategy/DeployStrategiesSpec.scala | 148 +++
.../layer/WorkerExecutionSpec.scala | 106 ++
.../logreplay/EmptyReplayLogManagerImplSpec.scala | 101 ++
.../logreplay/LogreplayPrimitivesSpec.scala | 409 +++++++
.../messaginglayer/AmberFIFOChannelSpec.scala | 202 ++++
.../messaginglayer/CongestionControlSpec.scala | 249 ++++
.../messaginglayer/FlowControlSpec.scala | 212 ++++
.../messaginglayer/OrderingEnforcerSpec.scala | 150 +++
.../messaginglayer/WorkerPortSpec.scala | 67 ++
.../architecture/scheduling/RegionPlanSpec.scala | 268 +++++
.../architecture/scheduling/ScheduleSpec.scala | 89 ++
.../scheduling/config/ChannelConfigSpec.scala | 212 ++++
.../scheduling/config/LinkConfigSpec.scala | 253 +++++
.../scheduling/config/SchedulingConfigsSpec.scala | 311 +++++
.../resourcePolicies/ResourcePoliciesSpec.scala | 174 +++
.../partitioners/PartitionersSpec.scala | 217 ++++
.../engine/architecture/worker/PauseTypeSpec.scala | 145 +++
.../worker/managers/WorkerManagersSpec.scala | 268 +++++
.../engine/common/CheckpointSubsystemSpec.scala | 177 +++
.../texera/amber/engine/common/UtilsSpec.scala | 156 +++
.../ambermessage/AmberMessageEnvelopesSpec.scala | 150 +++
.../common/ambermessage/DataPayloadSpec.scala | 84 ++
.../common/statetransition/StateManagerSpec.scala | 151 +++
.../statetransition/WorkerStateManagerSpec.scala | 131 +++
.../amber/engine/e2e/DataProcessingSpec.scala | 2 -
.../amber/engine/e2e/ReconfigurationSpec.scala | 201 +---
.../apache/texera/amber/engine/e2e/TestUtils.scala | 112 +-
.../engine/faulttolerance/CheckpointSpec.scala | 13 +
.../apache/texera/amber/error/ErrorUtilsSpec.scala | 207 ++++
.../texera/web/auth/UserAuthenticatorSpec.scala | 78 ++
.../web/service/ExecutionResultServiceSpec.scala | 24 +-
bin/access-control-service.dockerfile | 15 +-
bin/agent-service.dockerfile | 13 +-
bin/computing-unit-master.dockerfile | 29 +-
bin/computing-unit-worker.dockerfile | 29 +-
bin/config-service.dockerfile | 15 +-
bin/file-service.dockerfile | 15 +-
bin/licensing/check_binary_deps.py | 365 +++++-
bin/licensing/concat_license_binary.py | 327 ++++++
bin/licensing/test_check_binary_deps.py | 358 ++++++
bin/pylsp/Dockerfile | 9 +
DISCLAIMER => bin/single-node/DISCLAIMER | 6 -
.../single-node/LICENSE | 2 +-
NOTICE => bin/single-node/NOTICE | 0
bin/texera-web-application.dockerfile | 35 +-
bin/workflow-compiling-service.dockerfile | 15 +-
...flow-computing-unit-managing-service.dockerfile | 15 +-
bin/y-websocket-server/Dockerfile | 9 +
build.sbt | 15 +-
codecov.yml | 62 +
common/auth/build.sbt | 3 +-
.../org/apache/texera/auth/JwtAuthFilter.scala | 21 +-
.../scala/org/apache/texera/auth/JwtParser.scala | 62 +-
.../apache/texera/auth/UserActivityTracker.scala | 169 +++
.../org/apache/texera/auth/JwtParserSpec.scala | 200 ++++
.../texera/auth/UserActivityTrackerSpec.scala | 143 +++
common/config/src/main/resources/default.conf | 3 +
.../amber/pybuilder/EncodableInspector.scala | 4 +-
.../texera/amber/core/storage/FileResolver.scala | 6 +-
.../texera/amber/core/storage/VFSURIFactory.scala | 4 +-
.../core/storage/util/LakeFSStorageClient.scala | 2 +-
.../org/apache/texera/amber/core/tuple/Tuple.scala | 2 +-
.../org/apache/texera/amber/util/ArrowUtils.scala | 4 +-
.../texera/service/util/LargeBinaryManager.scala | 2 +-
.../texera/service/util/S3StorageClient.scala | 6 +-
.../amber/core/WorkflowRuntimeExceptionSpec.scala | 83 ++
.../core/executor/CoreExecutorReflectionSpec.scala | 229 ++++
.../amber/core/storage/VFSURIFactorySpec.scala | 109 ++
.../amber/core/storage/util/StorageUtilSpec.scala | 74 ++
.../amber/core/tuple/InternalMarkerSpec.scala | 76 ++
.../texera/amber/core/tuple/TupleUtilsSpec.scala | 110 ++
.../amber/core/workflow/PartitionInfoSpec.scala | 217 ++++
.../amber/core/workflow/WorkflowContextSpec.scala | 62 +
.../core/workflow/WorkflowCoreTypesSpec.scala | 340 ++++++
.../apache/texera/amber/util/ArrowUtilsSpec.scala | 271 +++++
.../apache/texera/amber/util/JSONUtilsSpec.scala | 157 +++
.../amber/util/VirtualIdentityUtilsSpec.scala | 163 +++
.../jsonSchema/annotations/JsonSchemaInject.java | 4 +-
.../sklearn/SklearnDummyClassifierOpDesc.scala | 2 +-
.../training/SklearnTrainingBaggingOpDesc.scala | 2 +-
.../SklearnTrainingDummyClassifierOpDesc.scala | 2 +-
.../operator/source/sql/SQLSourceOpExec.scala | 28 +-
.../sql/asterixdb/AsterixDBSourceOpExec.scala | 2 +-
.../amber/operator/aggregate/AggregateOpSpec.scala | 35 +
.../aggregate/AggregationOperationSpec.scala | 186 +++
.../amber/operator/flatmap/FlatMapOpExecSpec.scala | 118 ++
.../amber/operator/ifStatement/IfOpExecSpec.scala | 132 +++
.../operator/intersect/IntersectOpDescSpec.scala | 82 ++
.../amber/operator/limit/LimitOpExecSpec.scala | 85 ++
.../texera/amber/operator/map/MapOpExecSpec.scala | 125 ++
.../amber/operator/sink/ProgressiveUtilsSpec.scala | 219 ++++
.../sklearn/SklearnOpDescRegistrySpec.scala | 398 +++++++
.../amber/operator/sleep/SleepOpDescSpec.scala | 81 ++
.../operator/sort/StableMergeSortOpExecSpec.scala | 2 +-
.../source/fetcher/URLFetcherOpDescSpec.scala | 107 ++
.../ImageViz/ImageVisualizerOpDescSpec.scala | 59 +-
.../barChart/BarChartOpDescSpec.scala | 62 +-
.../bulletChart/BulletChartOpDescSpec.scala | 119 ++
.../funnelPlot/FunnelPlotOpDescSpec.scala | 95 ++
.../visualization/heatMap/HeatMapOpDescSpec.scala | 75 ++
.../lineChart/LineChartOpDescSpec.scala | 117 ++
.../pieChart/PieChartOpDescSpec.scala | 70 +-
.../volcanoPlot/VolcanoPlotOpDescSpec.scala | 95 ++
.../LICENSE-binary | 605 +---------
.../NOTICE-binary | 215 ----
computing-unit-managing-service/build.sbt | 4 +-
.../resource/ComputingUnitManagingResource.scala | 2 +-
.../LICENSE-binary | 286 +++--
NOTICE-binary => config-service/NOTICE-binary | 491 --------
config-service/build.sbt | 4 +-
LICENSE-binary => file-service/LICENSE-binary | 644 +----------
NOTICE-binary => file-service/NOTICE-binary | 230 ----
file-service/build.sbt | 4 +-
.../texera/service/resource/DatasetResource.scala | 2 +-
frontend/.gitignore | 3 +
.../LICENSE-iceberg.txt => frontend/LICENSE-binary | 271 +++--
frontend/angular.json | 52 +-
frontend/karma.conf.js | 71 --
frontend/package.json | 16 +-
frontend/src/app/app.module.ts | 142 ++-
frontend/src/app/common/formly/array.type.ts | 18 +-
.../collab-wrapper/collab-wrapper.component.ts | 3 +-
frontend/src/app/common/formly/multischema.type.ts | 5 +-
frontend/src/app/common/formly/null.type.ts | 1 -
frontend/src/app/common/formly/object.type.ts | 5 +-
.../preset-wrapper.component.spec.ts | 30 +-
.../preset-wrapper/preset-wrapper.component.ts | 21 +-
.../formly/repeat-dnd/repeat-dnd.component.ts | 23 +-
.../user/config/user-config.service.spec.ts | 5 +-
.../registration-request-modal.component.ts | 5 +-
.../app/common/service/user/user.service.spec.ts | 2 +
frontend/src/app/common/type/gui-config.ts | 1 +
.../execution/admin-execution.component.spec.ts | 11 +-
.../admin/execution/admin-execution.component.ts | 42 +-
.../component/admin/gmail/admin-gmail.component.ts | 27 +-
.../admin/settings/admin-settings.component.html | 9 +
.../settings/admin-settings.component.spec.ts | 3 +-
.../admin/settings/admin-settings.component.ts | 27 +-
.../component/admin/user/admin-user.component.html | 2 +-
.../admin/user/admin-user.component.spec.ts | 11 +-
.../component/admin/user/admin-user.component.ts | 54 +-
.../dashboard/component/dashboard.component.html | 1 +
.../component/dashboard.component.spec.ts | 17 +-
.../app/dashboard/component/dashboard.component.ts | 32 +-
.../conflicting-file-modal-content.component.ts | 1 -
.../files-uploader/files-uploader.component.ts | 35 +-
.../filters-instructions.component.spec.ts | 3 +-
.../filters-instructions.component.ts | 5 +-
.../component/user/filters/filters.component.html | 4 +-
.../user/filters/filters.component.spec.ts | 5 +-
.../component/user/filters/filters.component.ts | 32 +-
.../component/user/flarum/flarum.component.ts | 5 +-
.../user/list-item/list-item.component.spec.ts | 34 +-
.../user/list-item/list-item.component.ts | 29 +-
.../markdown-description.component.ts | 22 +-
.../user/search-bar/search-bar.component.ts | 15 +-
.../search-results/search-results.component.ts | 23 +-
.../component/user/search/search.component.ts | 20 +-
.../user/share-access/share-access.component.ts | 38 +-
.../user/sort-button/sort-button.component.ts | 20 +-
.../user/user-avatar/user-avatar.component.spec.ts | 3 +-
.../user/user-avatar/user-avatar.component.ts | 6 +-
.../user-computing-unit-list-item.component.ts | 29 +-
.../user-computing-unit.component.spec.ts | 24 +-
.../user-computing-unit.component.ts | 43 +-
.../dataset-detail.component.html | 27 +-
.../dataset-detail.component.scss | 30 +
.../dataset-detail.component.ts | 75 +-
.../user-dataset-file-renderer.component.spec.ts | 9 +-
.../user-dataset-file-renderer.component.ts | 29 +-
.../user-dataset-staged-objects-list.component.ts | 23 +-
.../user-dataset-version-creator.component.ts | 24 +-
.../user-dataset-version-filetree.component.ts | 18 +-
.../user-dataset-list-item.component.ts | 40 +-
.../user/user-dataset/user-dataset.component.html | 3 +-
.../user/user-dataset/user-dataset.component.ts | 23 +-
.../user/user-icon/user-icon.component.spec.ts | 10 +-
.../user/user-icon/user-icon.component.ts | 13 +-
.../public-project/public-project.component.ts | 32 +-
.../user-project-list-item.component.ts | 57 +-
.../ngbd-modal-add-project-workflow.component.ts | 20 +-
...ngbd-modal-remove-project-workflow.component.ts | 20 +-
.../user-project-section.component.ts | 29 +-
.../user/user-project/user-project.component.ts | 35 +-
.../user/user-quota/user-quota.component.spec.ts | 28 +-
.../user/user-quota/user-quota.component.ts | 45 +-
.../workflow-execution-history.component.ts | 63 +-
.../workflow-runtime-statistics.component.ts | 4 +-
.../highlight-search-terms.pipe.ts | 5 +-
.../user-workflow-list-item.component.spec.ts | 9 +-
.../user-workflow-list-item.component.ts | 47 +-
.../user-workflow/user-workflow.component.html | 7 +-
.../user-workflow/user-workflow.component.spec.ts | 31 +-
.../user/user-workflow/user-workflow.component.ts | 35 +-
.../service/user/download/download.service.spec.ts | 65 +-
.../workflow-executions.service.spec.ts | 7 +
.../app/hub/component/about/about.component.scss | 2 +-
.../hub/component/about/about.component.spec.ts | 56 +-
.../src/app/hub/component/about/about.component.ts | 5 +-
.../about/local-login/local-login.component.scss | 5 +-
.../about/local-login/local-login.component.ts | 30 +-
.../browse-section.component.spec.ts | 2 +-
.../browse-section/browse-section.component.ts | 18 +-
.../hub-search-result.component.ts | 3 +-
frontend/src/app/hub/component/hub.component.ts | 8 +-
.../landing-page/landing-page.component.ts | 3 +-
.../detail/hub-workflow-detail.component.ts | 24 +-
.../agent-interaction.component.ts | 38 +-
.../agent-panel/agent-chat/agent-chat.component.ts | 48 +-
.../agent/agent-panel/agent-panel.component.ts | 40 +-
.../agent-registration.component.ts | 26 +-
.../react-step-detail-modal.component.ts | 23 +-
.../annotation-suggestion.component.ts | 1 -
.../breakpoint-condition-input.component.spec.ts | 18 +-
.../breakpoint-condition-input.component.ts | 5 +-
.../code-debugger.component.spec.ts | 21 +-
.../code-editor-dialog/code-debugger.component.ts | 2 +-
.../code-editor-dialog/code-editor.component.ts | 21 +-
.../codearea-custom-template.component.ts | 14 +-
.../dataset-file-selector.component.ts | 18 +-
.../dataset-selection-modal.component.ts | 23 +-
.../dataset-version-selector.component.ts | 18 +-
.../left-panel/left-panel.component.spec.ts | 9 +-
.../component/left-panel/left-panel.component.ts | 33 +-
.../operator-label.component.spec.ts | 11 +-
.../operator-label/operator-label.component.ts | 4 +-
.../operator-menu/operator-menu.component.spec.ts | 18 +-
.../operator-menu/operator-menu.component.ts | 26 +-
.../left-panel/settings/settings.component.ts | 6 +-
.../time-travel/time-travel.component.ts | 23 +-
.../versions-list/versions-list.component.ts | 32 +-
.../coeditor-user-icon.component.spec.ts | 14 +-
.../coeditor-user-icon.component.ts | 15 +-
.../workspace/component/menu/menu.component.html | 12 +-
.../component/menu/menu.component.spec.ts | 24 +-
.../app/workspace/component/menu/menu.component.ts | 51 +-
.../computing-unit-selection.component.spec.ts | 2 +-
.../computing-unit-selection.component.ts | 54 +-
.../operator-property-edit-frame.component.spec.ts | 2 +-
.../operator-property-edit-frame.component.ts | 34 +-
.../port-property-edit-frame.component.spec.ts | 3 +-
.../port-property-edit-frame.component.ts | 22 +-
.../property-editor.component.spec.ts | 11 +-
.../property-editor/property-editor.component.ts | 30 +-
.../type-casting-display.component.spec.ts | 11 +-
.../type-casting-display.component.ts | 20 +-
.../result-exportation.component.ts | 43 +-
.../console-frame/console-frame.component.spec.ts | 11 +-
.../console-frame/console-frame.component.ts | 49 +-
.../error-frame/error-frame.component.spec.ts | 13 +-
.../error-frame/error-frame.component.ts | 14 +-
.../result-panel/result-panel-modal.component.ts | 3 +-
.../result-panel/result-panel.component.spec.ts | 11 +-
.../result-panel/result-panel.component.ts | 36 +-
.../result-table-frame.component.spec.ts | 11 +-
.../result-table-frame.component.ts | 37 +-
.../visualization-frame-content.component.ts | 1 -
.../nz-modal-comment-box.component.ts | 40 +-
.../context-menu/context-menu.component.spec.ts | 175 ++-
.../context-menu/context-menu.component.ts | 6 +-
.../mini-map/mini-map.component.spec.ts | 12 +-
.../workflow-editor/mini-map/mini-map.component.ts | 16 +-
.../workflow-editor.component.spec.ts | 44 +-
.../workflow-editor/workflow-editor.component.ts | 8 +-
.../app/workspace/component/workspace.component.ts | 24 +-
.../service/drag-drop/drag-drop.service.spec.ts | 10 +-
.../dynamic-schema/dynamic-schema.service.spec.ts | 4 +-
.../execute-workflow.service.spec.ts | 32 +-
.../service/joint-ui/joint-ui.service.spec.ts | 7 +
.../operator-debug/udf-debug.service.spec.ts | 49 +-
.../operator-menu/operator-menu.service.spec.ts | 24 +-
.../service/preset/preset.service.spec.ts | 28 +-
.../model/coeditor-presence.service.spec.ts | 6 +-
.../model/joint-graph-wrapper.spec.ts | 2 +-
.../workflow-graph/model/sync-texera-model.spec.ts | 28 +-
.../workflow-graph/model/workflow-graph.spec.ts | 20 +-
.../workflow-result-export.service.spec.ts | 126 +--
.../workflow-result.service.spec.ts | 33 +-
.../workflow-websocket.service.spec.ts | 8 +-
frontend/src/jsdom-svg-polyfill.ts | 179 +++
.../execution-api.ts => frontend/src/main.test.ts | 28 +-
frontend/src/test-zone-setup.ts | 96 ++
frontend/src/test.ts | 25 -
frontend/src/tsconfig.spec.json | 51 +-
frontend/src/tsconfig.test.json | 16 +
.../index.ts => frontend/src/vitest-globals.d.ts | 8 +-
frontend/vitest.config.ts | 37 +
frontend/yarn.lock | 1196 +++++++++++---------
project/AddMetaInfLicenseFiles.scala | 19 +-
.../LICENSE-binary | 635 +----------
.../NOTICE-binary | 164 ---
workflow-compiling-service/build.sbt | 4 +-
370 files changed, 21893 insertions(+), 7619 deletions(-)
create mode 100644 .github/scripts/compose-backport-message.py
delete mode 100644 .github/workflows/auto-assign.yml
create mode 100644 .github/workflows/auto-queue.yml
delete mode 100644 .github/workflows/issue-triage.yml
create mode 100644 .github/workflows/license-binary-checker.yml
create mode 100644 .github/workflows/pr-assignment.yml
create mode 100644 .github/workflows/take-commands.yml
copy licenses/LICENSE-iceberg.txt => access-control-service/LICENSE-binary
(55%)
copy NOTICE-binary => access-control-service/NOTICE-binary (74%)
create mode 100644
access-control-service/src/main/scala/org/apache/texera/service/activity/UserActivityEventListener.scala
create mode 100644
access-control-service/src/test/scala/org/apache/texera/service/AccessControlServiceRunSpec.scala
create mode 100644
access-control-service/src/test/scala/org/apache/texera/service/activity/UserActivityEventListenerSpec.scala
copy licenses/LICENSE-hadoop-shaded.txt => agent-service/LICENSE-binary (77%)
create mode 100644 agent-service/src/agent/tools/result-formatting.test.ts
create mode 100644 agent-service/src/agent/tools/tools-utility.test.ts
create mode 100644 agent-service/src/agent/util/auto-layout.test.ts
copy LICENSE-binary => amber/LICENSE-binary-java (65%)
copy licenses/LICENSE-iceberg.txt => amber/LICENSE-binary-python (74%)
copy NOTICE-binary => amber/NOTICE-binary (82%)
create mode 100644
amber/src/main/python/core/architecture/handlers/control/test_update_executor_handler.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_console_message_manager.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_embedded_control_message_manager.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_exception_manager.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_state_processing_manager.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_statistics_manager.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_tuple_processing_manager.py
create mode 100644
amber/src/main/python/core/architecture/rpc/test_async_rpc_client.py
create mode 100644
amber/src/main/python/core/architecture/sendsemantics/test_partitioners.py
create mode 100644 amber/src/main/python/core/models/test_operator.py
create mode 100644 amber/src/main/python/core/runnables/test_heartbeat.py
create mode 100644
amber/src/main/python/core/util/console_message/test_replace_print.py
create mode 100644
amber/src/main/python/core/util/customized_queue/test_inner.py
create mode 100644 amber/src/main/python/core/util/thread/test_atomic.py
create mode 100644
amber/src/main/python/core/util/virtual_identity/test_virtual_identity.py
create mode 100644
amber/src/main/python/pytexera/storage/test_dataset_file_document.py
copy
amber/src/test/{scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
=>
integration/org/apache/texera/amber/engine/e2e/ReconfigurationIntegrationSpec.scala}
(57%)
create mode 100644
amber/src/test/integration/org/apache/texera/amber/tags/IntegrationTest.java
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/common/ProcessingStepCursorSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/controller/GlobalReplayManagerSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/controller/execution/LinkExecutionSpec.scala
copy
amber/src/{main/scala/org/apache/texera/amber/engine/architecture/controller/execution/LinkExecution.scala
=>
test/scala/org/apache/texera/amber/engine/architecture/controller/execution/WorkerPortExecutionSpec.scala}
(54%)
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/deploysemantics/AddressInfoSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/deploysemantics/deploystrategy/DeployStrategiesSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/deploysemantics/layer/WorkerExecutionSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/logreplay/EmptyReplayLogManagerImplSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/logreplay/LogreplayPrimitivesSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/messaginglayer/AmberFIFOChannelSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/messaginglayer/CongestionControlSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/messaginglayer/FlowControlSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/messaginglayer/OrderingEnforcerSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/messaginglayer/WorkerPortSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionPlanSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/ScheduleSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/config/ChannelConfigSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/config/LinkConfigSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/config/SchedulingConfigsSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/resourcePolicies/ResourcePoliciesSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/sendsemantics/partitioners/PartitionersSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/PauseTypeSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/managers/WorkerManagersSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/CheckpointSubsystemSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/UtilsSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/ambermessage/AmberMessageEnvelopesSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/ambermessage/DataPayloadSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/statetransition/StateManagerSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/common/statetransition/WorkerStateManagerSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/error/ErrorUtilsSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/web/auth/UserAuthenticatorSpec.scala
create mode 100755 bin/licensing/concat_license_binary.py
create mode 100644 bin/licensing/test_check_binary_deps.py
copy DISCLAIMER => bin/single-node/DISCLAIMER (61%)
copy licenses/LICENSE-awssdk-third-party-jackson.txt =>
bin/single-node/LICENSE (100%)
copy NOTICE => bin/single-node/NOTICE (100%)
create mode 100644 codecov.yml
create mode 100644
common/auth/src/main/scala/org/apache/texera/auth/UserActivityTracker.scala
create mode 100644
common/auth/src/test/scala/org/apache/texera/auth/JwtParserSpec.scala
create mode 100644
common/auth/src/test/scala/org/apache/texera/auth/UserActivityTrackerSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/WorkflowRuntimeExceptionSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/executor/CoreExecutorReflectionSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/storage/VFSURIFactorySpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/storage/util/StorageUtilSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/tuple/InternalMarkerSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/tuple/TupleUtilsSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/workflow/PartitionInfoSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/workflow/WorkflowContextSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/workflow/WorkflowCoreTypesSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/util/ArrowUtilsSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/util/JSONUtilsSpec.scala
create mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/util/VirtualIdentityUtilsSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/aggregate/AggregationOperationSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/flatmap/FlatMapOpExecSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/ifStatement/IfOpExecSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/intersect/IntersectOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/limit/LimitOpExecSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/map/MapOpExecSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/sink/ProgressiveUtilsSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/sklearn/SklearnOpDescRegistrySpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/sleep/SleepOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/source/fetcher/URLFetcherOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/visualization/bulletChart/BulletChartOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/visualization/funnelPlot/FunnelPlotOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/visualization/heatMap/HeatMapOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/visualization/lineChart/LineChartOpDescSpec.scala
create mode 100644
common/workflow-operator/src/test/scala/org/apache/texera/amber/operator/visualization/volcanoPlot/VolcanoPlotOpDescSpec.scala
copy LICENSE-binary => computing-unit-managing-service/LICENSE-binary (60%)
copy NOTICE-binary => computing-unit-managing-service/NOTICE-binary (88%)
copy licenses/LICENSE-iceberg.txt => config-service/LICENSE-binary (54%)
copy NOTICE-binary => config-service/NOTICE-binary (74%)
copy LICENSE-binary => file-service/LICENSE-binary (56%)
copy NOTICE-binary => file-service/NOTICE-binary (87%)
copy licenses/LICENSE-iceberg.txt => frontend/LICENSE-binary (68%)
delete mode 100644 frontend/karma.conf.js
create mode 100644 frontend/src/jsdom-svg-polyfill.ts
copy agent-service/src/api/execution-api.ts => frontend/src/main.test.ts (59%)
create mode 100644 frontend/src/test-zone-setup.ts
delete mode 100644 frontend/src/test.ts
create mode 100644 frontend/src/tsconfig.test.json
copy agent-service/src/types/index.ts => frontend/src/vitest-globals.d.ts (69%)
create mode 100644 frontend/vitest.config.ts
rename LICENSE-binary => workflow-compiling-service/LICENSE-binary (57%)
rename NOTICE-binary => workflow-compiling-service/NOTICE-binary (91%)
