This is an automated email from the ASF dual-hosted git repository.
dominikriemer pushed a change to branch migrate-configuration-storage
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3684b8d996 Fix user storage cache
add 644fd68559 fix: Properly cleanup subscriptions in kiosk mode (#4622)
add bd263a316a feat(#4577): Add last updated time to dashboard kiosk,
improve performance (#4629)
add ff1dee49c6 chore(deps): bump actions/cache from 5 to 5.0.5 (#4626)
add cc922f4e13 fix: Ignore unknown fields in ImportGenerator (#4630)
add 055ada4986 Fix VS Code JMX port conflict for dev launch (#4620)
add 8ac28303f1 chore(deps): bump actions/checkout from 6.0.3 to 7.0.0
(#4623)
add 067704522d fix: Split chart request refresh strategies (#4634)
add 0423651c77 feat(#4633): Move dataset count display into dataset
overview (#4637)
add 60d11642a8 chore(deps): bump actions/setup-python from 5 to 6.2.0
(#4636)
add 590b266bec chore: Improve startup logging (#4638)
add e7dafb922b fix: Improve retry of failed PLC connections (#4572)
add 40d0ac4229 fix(#4640): Add missing sorting to adapter and dataset
columns (#4645)
add 8d454cb075 feat: modernize Python Client syntax (PEP 585, PEP 604)
(#4628)
add fd23b5f509 Update README.md
add 39f059281e fix: consistent spacing in translation files (#4639)
add 82296def81 Merge branch 'dev' into migrate-configuration-storage
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 2 +-
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/extensions-docs.yml | 2 +-
.github/workflows/go-client-e2e-test.yml | 4 +-
.github/workflows/go-client.yml | 2 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/java-client-e2e-test.yml | 4 +-
.github/workflows/mvn-integration-test.yml | 2 +-
.github/workflows/pr-validation.yml | 18 +-
.github/workflows/pypi-deployment.yml | 4 +-
.github/workflows/python-docs.yml | 6 +-
.vscode/launch.json | 14 ++
README.md | 2 -
.../streampipes/client/client.py | 5 +-
.../streampipes/client/config.py | 7 +-
.../streampipes/client/credential_provider.py | 13 +-
.../streampipes/endpoint/api/data_lake_measure.py | 28 +--
.../streampipes/endpoint/api/data_stream.py | 5 +-
.../streampipes/endpoint/api/version.py | 7 +-
.../streampipes/endpoint/endpoint.py | 11 +-
.../streampipes/function_zoo/river_function.py | 15 +-
.../streampipes/functions/broker/consumer.py | 2 +-
.../functions/broker/kafka/kafka_consumer.py | 2 +-
.../functions/broker/kafka/kafka_publisher.py | 4 +-
.../functions/broker/nats/nats_consumer.py | 2 +-
.../functions/broker/nats/nats_publisher.py | 4 +-
.../functions/broker/output_collector.py | 5 +-
.../streampipes/functions/broker/publisher.py | 4 +-
.../streampipes/functions/function_handler.py | 10 +-
.../streampipes/functions/registration.py | 5 +-
.../streampipes/functions/streampipes_function.py | 10 +-
.../functions/utils/async_iter_handler.py | 7 +-
.../functions/utils/data_stream_context.py | 3 +-
.../functions/utils/data_stream_generator.py | 5 +-
.../functions/utils/function_context.py | 3 +-
.../streampipes/model/common.py | 59 +++--
.../model/container/data_lake_measures.py | 3 +-
.../streampipes/model/container/data_streams.py | 3 +-
.../model/container/resource_container.py | 7 +-
.../streampipes/model/container/versions.py | 3 +-
.../model/resource/data_lake_measure.py | 11 +-
.../streampipes/model/resource/data_series.py | 10 +-
.../streampipes/model/resource/data_stream.py | 31 ++-
.../streampipes/model/resource/exceptions.py | 3 +-
.../model/resource/function_definition.py | 11 +-
.../streampipes/model/resource/query_result.py | 12 +-
.../streampipes/model/resource/resource.py | 3 +-
.../streampipes/model/resource/version.py | 5 +-
.../tests/client/test_endpoint.py | 3 +-
.../export/dataimport/ImportGenerator.java | 2 +-
.../plc/adapter/generic/GenericPlc4xAdapter.java | 9 +-
.../connection/ContinuousPlcRequestReader.java | 15 +-
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 9 +-
.../plc/cache/SpConnectionContainer.java | 72 +++---
.../plc/adapter/ConnectionContainerReproTest.java | 110 +++++++++
.../health/monitoring/PipelineHealthCheck.java | 3 +-
.../ExtensionsServiceEndpointGenerator.java | 2 +-
.../impl/datalake/DataLakeMeasureResource.java | 60 +++--
.../rest/impl/datalake/DataLakeResource.java | 79 ++++++-
.../datalake/KioskDashboardDataLakeResource.java | 44 ++++
.../streampipes/service/core/PostStartupTask.java | 8 +-
.../service/core/StreamPipesCoreApplication.java | 6 +-
.../service/core/WebSecurityConfig.java | 15 +-
.../service/core/migrations/MigrationsHandler.java | 2 +-
.../src/main/resources/application.properties | 6 +-
.../management/service/SpUserDetailsService.java | 3 +
ui/cypress/support/utils/chart/ChartBtns.ts | 36 ---
ui/cypress/support/utils/chart/ChartUtils.ts | 24 --
ui/cypress/support/utils/dataset/DatasetBtns.ts | 32 ++-
ui/cypress/support/utils/dataset/DatasetUtils.ts | 130 +++++++----
ui/cypress/tests/chart/configuration.smoke.spec.ts | 40 ++--
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 13 +-
ui/cypress/tests/dataset/csvImport.spec.ts | 18 +-
.../restartStreamPipes/restartStreamPipes2.ts | 11 +-
ui/deployment/i18n/de.json | 7 +-
ui/deployment/i18n/en.json | 7 +-
ui/deployment/i18n/pl.json | 7 +-
ui/package.json | 2 +-
.../src/lib/apis/dashboard-kiosk.service.ts | 16 ++
.../src/lib/apis/datalake-rest.service.ts | 28 ++-
.../dashboard-data-request-coordinator.service.ts | 158 +++++++++++++
.../lib/query/data-view-query-generator.service.ts | 52 +++++
.../platform-services/src/public-api.ts | 1 +
.../base/base-data-explorer-widget.directive.ts | 120 +++++++---
.../chart-shared/services/chart-shared.service.ts | 21 +-
.../existing-adapters.component.html | 7 +-
.../existing-adapters.component.ts | 31 ++-
.../last-updated-formatter.service.ts | 101 +++++++++
.../kiosk/dashboard-kiosk.component.html | 13 ++
.../kiosk/dashboard-kiosk.component.scss | 7 +
.../components/kiosk/dashboard-kiosk.component.ts | 115 +++++++---
.../components/panel/dashboard-panel.component.ts | 2 +-
.../datalake-configuration-entry.ts | 6 +-
.../datalake-configuration.component.html | 88 +-------
.../datalake-configuration.component.ts | 88 ++++----
.../daily-event-counts-chart.component.html} | 16 +-
.../daily-event-counts-chart.component.scss} | 12 +-
.../daily-event-counts-chart.component.ts | 92 ++++++++
.../dataset-details-metrics.component.html} | 50 +++--
.../dataset-details-metrics.component.scss} | 4 +-
.../dataset-details-metrics.component.ts | 248 +++++++++++++++++++++
.../dataset-details/dataset-details-tabs.ts | 5 +
ui/src/app/dataset/dataset.routes.ts | 5 +
103 files changed, 1756 insertions(+), 687 deletions(-)
create mode 100644
ui/projects/streampipes/platform-services/src/lib/query/dashboard-data-request-coordinator.service.ts
create mode 100644
ui/src/app/core-services/time-formatting/last-updated-formatter.service.ts
copy
ui/src/app/{connect/dialog/adapter-started/adapter-started-preview/adapter-started-preview.component.html
=>
dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.html}
(72%)
copy
ui/src/app/{chart-shared/components/charts/base/no-data/no-data-in-date-range.component.scss
=>
dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.scss}
(86%)
create mode 100644
ui/src/app/dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.ts
copy
ui/src/app/{connect/components/adapter-details/adapter-details-metrics/adapter-details-metrics.component.html
=>
dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.html}
(53%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/sp-exception-message/exception-details-dialog/exception-details-dialog.component.scss
=>
src/app/dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.scss}
(95%)
create mode 100644
ui/src/app/dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.ts
