This is an automated email from the ASF dual-hosted git repository.
JHoelli pushed a change to branch 4716-add-loading-banner-for-asset-links
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 241773d611 translate
add 07d9eff639 fix: Clean up adapter and pipeline lifecycle (#4719)
add 2d44c44cc8 feat(#4721): add CSV import progress tracking (#4722)
add b70ed30a88 reaftor: migrate pyproject.toml metadata to Python standard
in PEP 621 to fix poetry deprecations (#4649)
add 807f4e3918 chore: Improve timeout handling of OPC UA adapter (#4723)
add 369a821f29 fix: PLC4X cache recovery after failed read execution
(#4648)
add f8ec4d2ae3 feat(#4690): deprecate legacy plc4x s7 and modbus adapters
(#4691)
add 6b0c0bdfe5 #4683 fix(msteams): migrate sink to Power Automate workflow
format (#4684)
add 000b916232 Merge branch 'dev' into
4716-add-loading-banner-for-asset-links
No new revisions were added by this update.
Summary of changes:
streampipes-client-python/poetry.lock | 2 +-
streampipes-client-python/pyproject.toml | 40 +-
.../api/monitoring/SpMonitoringManager.java | 18 +-
.../connect/AdapterWorkerManagement.java | 53 ++-
.../management/connect/PullAdapterScheduler.java | 19 +-
.../connect/adapter/model/EventCollector.java | 11 +-
.../adapter/model/pipeline/AdapterPipeline.java | 14 +-
.../elements/SendToBrokerAdapterSink.java | 7 +-
...sSingleton.java => RunningAdapterInstance.java} | 7 +-
.../management/init/RunningAdapterInstances.java | 25 +-
.../management/init/RunningInstances.java | 4 +-
.../pe/DataProcessorPipelineElementManagement.java | 4 +-
.../pe/DataSinkPipelineElementManagement.java | 4 +-
.../pe/InvocablePipelineElementManagement.java | 4 +-
.../connect/AdapterWorkerManagementTest.java | 41 ++
.../connect/PullAdapterSchedulerTest.java | 55 +++
.../connectors/opcua/adapter/OpcUaAdapter.java | 13 +-
.../opcua/alarms/OpcUaAlarmEventSubscriber.java | 32 +-
.../opcua/client/ConnectedOpcUaClient.java | 37 ++
.../alarms/OpcUaAlarmEventSubscriberTest.java | 68 +++
.../opcua/client/ConnectedOpcUaClientTest.java | 66 +++
.../connection/ContinuousPlcRequestReader.java | 10 +-
.../plc/adapter/modbus/Plc4xModbusAdapter.java | 5 +
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 5 +
.../plc/cache/SpLeasedPlcConnection.java | 26 +-
.../documentation.md | 3 +
.../documentation.md | 4 +
.../plc/adapter/ConnectionContainerReproTest.java | 108 +++++
.../notifications/jvm/msteams/MSTeamsSink.java | 518 +++++++++++----------
.../documentation.md | 21 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 230 +++++----
.../OpcUaAdapterReadTimeoutReproductionTest.java | 177 +++++++
.../adapters/opcua/OpcUaAdapterTestHarness.java | 34 +-
.../containers/OpcUaDemoServerContainer.java | 7 +-
.../messaging/kafka/SpKafkaProducer.java | 28 +-
...IssueType.java => CsvImportJobStartResult.java} | 23 +-
...mportTargetMode.java => CsvImportJobState.java} | 7 +-
...svImportResult.java => CsvImportJobStatus.java} | 60 ++-
.../datalake/importer/CsvImportPreviewResult.java | 9 +
.../http/InvokePipelineElementSubmitter.java | 2 +-
.../http/PipelineElementExtensionRequest.java | 5 +-
.../http/PipelineElementRollbackTest.java | 136 ++++++
.../rest/impl/datalake/DataLakeResource.java | 10 +-
.../importer/CsvDataLakeImportService.java | 71 ++-
.../datalake/importer/CsvImportJobManager.java | 162 +++++++
.../impl/datalake/importer/CsvImportParser.java | 29 +-
.../datalake/importer/CsvImportUploadStorage.java | 20 +-
.../datalake/importer/DataLakeImportResource.java | 21 +-
.../rest/impl/datalake/DataLakeResourceTest.java | 17 +
.../importer/CsvDataLakeImportServiceTest.java | 65 +++
.../datalake/importer/CsvImportParserTest.java | 1 +
.../core/migrations/AvailableMigrations.java | 2 +
.../MigratePlc4xS7AdaptersToGenericAdapter.java | 443 ++++++++++++++++++
...MigratePlc4xS7AdaptersToGenericAdapterTest.java | 294 ++++++++++++
.../standalone/manager/ProtocolManager.java | 32 +-
.../runtime/StandaloneEventProcessorRuntime.java | 57 ++-
.../runtime/StandaloneEventSinkRuntime.java | 45 +-
.../runtime/StandalonePipelineElementRuntime.java | 77 ++-
ui/STYLEGUIDE.md | 14 +
.../support/utils/dataset/DataLakeSeedUtils.ts | 69 ++-
ui/deployment/i18n/de.json | 3 +-
ui/deployment/i18n/en.json | 3 +-
ui/deployment/i18n/pl.json | 3 +-
.../src/lib/apis/datalake-rest.service.ts | 18 +-
.../src/lib/model/datalake/csv-import.model.ts | 16 +
.../progress-bar.component.html} | 27 +-
.../progress-bar/progress-bar.component.scss} | 23 +-
.../progress-bar/progress-bar.component.ts | 57 +++
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../csv-import-dialog.component.html | 2 +
.../csv-import-dialog.component.ts | 92 +++-
.../csv-import-upload-state.component.html | 19 +-
.../csv-import-upload-state.component.scss | 19 +-
.../csv-import-upload-state.component.ts | 10 +-
74 files changed, 3069 insertions(+), 595 deletions(-)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/{IDeclarersSingleton.java
=> RunningAdapterInstance.java} (80%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/alarms/OpcUaAlarmEventSubscriberTest.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/client/ConnectedOpcUaClientTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/OpcUaAdapterReadTimeoutReproductionTest.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportSchemaIssueType.java
=> CsvImportJobStartResult.java} (73%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportTargetMode.java
=> CsvImportJobState.java} (93%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportResult.java
=> CsvImportJobStatus.java} (56%)
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/execution/http/PipelineElementRollbackTest.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportJobManager.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/connect/MigratePlc4xS7AdaptersToGenericAdapter.java
create mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/migrations/v099/connect/MigratePlc4xS7AdaptersToGenericAdapterTest.java
copy
ui/projects/streampipes/shared-ui/src/lib/components/{input-schema-panel/input-schema-property/input-schema-property.component.html
=> progress-bar/progress-bar.component.html} (58%)
copy
ui/projects/streampipes/shared-ui/src/lib/{dialog/data-download-dialog/components/select-data/select-data.component.scss
=> components/progress-bar/progress-bar.component.scss} (72%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/progress-bar/progress-bar.component.ts
