This is an automated email from the ASF dual-hosted git repository. dominikriemer pushed a commit to branch add-running-instance-dialog-registered-services in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 699bd0f32d1e33cd4d58feafc5fb7eceee5056d0 Author: Dominik Riemer <[email protected]> AuthorDate: Wed Jul 8 10:10:03 2026 +0200 Add translations --- .../monitoring/ExtensionInstanceRemovalService.java | 18 ++++++++++++++++-- ui/deployment/i18n/de.json | 8 ++------ ui/deployment/i18n/en.json | 8 ++------ ui/deployment/i18n/pl.json | 8 ++------ ...sions-service-running-instances-dialog.component.ts | 14 +++++++++----- 5 files changed, 31 insertions(+), 25 deletions(-) diff --git a/streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceRemovalService.java b/streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceRemovalService.java index 1fa612fbc8..09a37c86eb 100644 --- a/streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceRemovalService.java +++ b/streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceRemovalService.java @@ -33,6 +33,8 @@ import org.apache.streampipes.storage.api.system.IExtensionsServiceStorage; import org.apache.streampipes.svcdiscovery.api.model.SpServiceUrlProvider; import com.fasterxml.jackson.core.JsonProcessingException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.Objects; @@ -40,6 +42,8 @@ import java.util.stream.Stream; public class ExtensionInstanceRemovalService { + private static final Logger LOG = LoggerFactory.getLogger(ExtensionInstanceRemovalService.class); + private final IExtensionsServiceStorage extensionsServiceStorage; private final ResourceProvider resourceProvider; private final ExtensionServiceRequestManager extensionRequestManager; @@ -64,11 +68,21 @@ public class ExtensionInstanceRemovalService { ).getRunningInstances(serviceId); for (var adapter : runningInstances.adapters()) { - removeAdapterInstance(serviceId, adapter.instanceId()); + try { + removeAdapterInstance(serviceId, adapter.instanceId()); + } catch (IOException e) { + LOG.warn("Could not remove adapter instance {} from service {} during bulk removal", + adapter.instanceId(), serviceId, e); + } } for (var pipelineElement : runningInstances.pipelineElements()) { - removePipelineElementInstance(serviceId, pipelineElement.instanceId()); + try { + removePipelineElementInstance(serviceId, pipelineElement.instanceId()); + } catch (IOException e) { + LOG.warn("Could not remove pipeline element instance {} from service {} during bulk removal", + pipelineElement.instanceId(), serviceId, e); + } } } diff --git a/ui/deployment/i18n/de.json b/ui/deployment/i18n/de.json index 5f37866fe6..9a5288c723 100644 --- a/ui/deployment/i18n/de.json +++ b/ui/deployment/i18n/de.json @@ -221,7 +221,6 @@ "Configure labels which can be assigned to assets and other resources": "Labels konfigurieren, die Assets und anderen Ressourcen zugewiesen werden können", "Configure schema": "Schema konfigurieren", "Configure trusted and rejected OPC-UA certificates": "Konfiguration der vertrauenswürdigen und abgelehnten OPC-UA Zertifikate", - "Configured": "Konfiguriert", "Confirm password": "Passwort bestätigen", "Connect Adapter": "Adapter anschließen", "Connection could not be established.": "Die Verbindung konnte nicht hergestellt werden.", @@ -335,13 +334,13 @@ "Delete the dataset entirely. All historical data is lost!": "Löschen Sie den Datensatz vollständig. Alle historischen Daten gehen verloren!", "Delete user": "Benutzer löschen", "Deleted fields": "Gelöschte Felder", + "Deleted instances of active pipelines or adapters will be redeployed by the health check.": "Gelöschte Instanzen aktiver Pipelines oder Adapter werden durch den Health Check erneut bereitgestellt.", "Deleting data...": "Daten löschen...", "Deleting pipeline...": "Löschen der Pipeline...", "Delimiter": "Trennzeichen", "Delta font size": "Delta-Schriftgröße", "Depending on number and size of exported files, this might take a while...": "Je nach Anzahl und Größe der exportierten Dateien kann dies eine Weile dauern...", "Description": "Beschreibung", - "Deselect All": "Alle abwählen", "Deselect all": "Alle abwählen", "Details": "Einzelheiten", "Dialog Title": "Dialogfeld", @@ -773,9 +772,6 @@ "Order": "Sortieren", "Original": "Original", "Original (Parsed)": "Original (geparst)", - "Orphaned": "Verwaist", - "Orphaned adapter instance": "Verwaiste Adapterinstanz", - "Orphaned pipeline element instance": "Verwaiste Pipeline-Element-Instanz", "Others Label": "Beschriftung für Sonstige", "Output Topics": "Output-Topics", "Output stream": "Ausgabestream", @@ -863,6 +859,7 @@ "Refresh charts": "Diagramme aktualisieren", "Refresh interval": "Aktualisierungsintervall", "Refresh metrics": "Metriken aktualisieren", + "Refresh running instances": "Laufende Instanzen aktualisieren", "Region": "Region", "Register": "Registrieren", "Registered services": "Registrierte Services", @@ -956,7 +953,6 @@ "Second": "Sekunde", "Secret Key": "Secret Key", "Select Adapter": "Adapter auswählen", - "Select All": "Alle auswählen", "Select CSV file": "CSV-Datei auswählen", "Select Data": "Daten auswählen", "Select Fields": "Felder auswählen", diff --git a/ui/deployment/i18n/en.json b/ui/deployment/i18n/en.json index 20f4d098be..a2a0063823 100644 --- a/ui/deployment/i18n/en.json +++ b/ui/deployment/i18n/en.json @@ -221,7 +221,6 @@ "Configure labels which can be assigned to assets and other resources": null, "Configure schema": null, "Configure trusted and rejected OPC-UA certificates": null, - "Configured": null, "Confirm password": null, "Connect Adapter": null, "Connection could not be established.": null, @@ -335,13 +334,13 @@ "Delete the dataset entirely. All historical data is lost!": null, "Delete user": null, "Deleted fields": null, + "Deleted instances of active pipelines or adapters will be redeployed by the health check.": null, "Deleting data...": null, "Deleting pipeline...": null, "Delimiter": null, "Delta font size": null, "Depending on number and size of exported files, this might take a while...": null, "Description": null, - "Deselect All": null, "Deselect all": null, "Details": null, "Dialog Title": null, @@ -773,9 +772,6 @@ "Order": null, "Original": null, "Original (Parsed)": null, - "Orphaned": null, - "Orphaned adapter instance": null, - "Orphaned pipeline element instance": null, "Others Label": null, "Output Topics": null, "Output stream": null, @@ -863,6 +859,7 @@ "Refresh charts": null, "Refresh interval": null, "Refresh metrics": null, + "Refresh running instances": null, "Region": null, "Register": null, "Registered services": null, @@ -956,7 +953,6 @@ "Second": null, "Secret Key": null, "Select Adapter": null, - "Select All": null, "Select CSV file": null, "Select Data": null, "Select Fields": null, diff --git a/ui/deployment/i18n/pl.json b/ui/deployment/i18n/pl.json index c548ab39cd..a54c8b4a4a 100644 --- a/ui/deployment/i18n/pl.json +++ b/ui/deployment/i18n/pl.json @@ -221,7 +221,6 @@ "Configure labels which can be assigned to assets and other resources": "Skonfiguruj etykiety, które mogą być przypisywane do zasobów i innych zasobów", "Configure schema": "Skonfiguruj schemat", "Configure trusted and rejected OPC-UA certificates": "Skonfiguruj zaufane i odrzucone certyfikaty OPC-UA", - "Configured": "Skonfigurowane", "Confirm password": "Potwierdź hasło", "Connect Adapter": "Podłącz adapter", "Connection could not be established.": "Nie udało się nawiązać połączenia.", @@ -335,13 +334,13 @@ "Delete the dataset entirely. All historical data is lost!": "Usuń cały zestaw danych. Wszystkie dane historyczne zostaną utracone!", "Delete user": "Usuń użytkownika", "Deleted fields": "Usunięte pola", + "Deleted instances of active pipelines or adapters will be redeployed by the health check.": "Usunięte instancje aktywnych strumieni lub adapterów zostaną ponownie wdrożone przez mechanizm sprawdzania stanu.", "Deleting data...": "Usuwanie danych...", "Deleting pipeline...": "Usuwanie strumienia...", "Delimiter": "Separator", "Delta font size": "Rozmiar czcionki delty", "Depending on number and size of exported files, this might take a while...": "W zależności od liczby i rozmiaru eksportowanych plików może to chwilę potrwać...", "Description": "Opis", - "Deselect All": "Odznacz wszystko", "Deselect all": "Odznacz wszystko", "Details": "Szczegóły", "Dialog Title": "Tytuł okna dialogowego", @@ -773,9 +772,6 @@ "Order": "Kolejność", "Original": "Oryginalne", "Original (Parsed)": "Oryginał (przetworzony)", - "Orphaned": "Osierocone", - "Orphaned adapter instance": "Osierocona instancja adaptera", - "Orphaned pipeline element instance": "Osierocona instancja elementu strumienia", "Others Label": "Etykieta dla pozostałych", "Output Topics": "Tematy wyjściowe", "Output stream": "Strumień wyjściowy", @@ -863,6 +859,7 @@ "Refresh charts": "Odśwież wykresy", "Refresh interval": "Interwał odświeżania", "Refresh metrics": "Odśwież metryki", + "Refresh running instances": "Odśwież uruchomione instancje", "Region": "Region", "Register": "Zarejestruj się", "Registered services": "Zarejestrowane usługi", @@ -956,7 +953,6 @@ "Second": "Sekunda", "Secret Key": "Klucz tajny", "Select Adapter": "Wybierz adapter", - "Select All": "Zaznacz wszystko", "Select CSV file": "Wybierz plik CSV", "Select Data": "Wybierz dane", "Select Fields": "Wybierz pola", diff --git a/ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.ts b/ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.ts index c9b619b67a..02dcb597ae 100644 --- a/ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.ts +++ b/ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.ts @@ -219,14 +219,18 @@ export class SpExtensionsServiceRunningInstancesDialogComponent implements OnIni } confirmRemoval(): void { - if (!this.pendingRemoval) { + const pendingRemoval = this.pendingRemoval; + + if (!pendingRemoval) { return; } - if (this.pendingRemoval.type === 'adapter') { - this.removeAdapterInstance(this.pendingRemoval.item); - } else if (this.pendingRemoval.type === 'pipelineElement') { - this.removePipelineElementInstance(this.pendingRemoval.item); + this.pendingRemoval = undefined; + + if (pendingRemoval.type === 'adapter') { + this.removeAdapterInstance(pendingRemoval.item); + } else if (pendingRemoval.type === 'pipelineElement') { + this.removePipelineElementInstance(pendingRemoval.item); } else { this.removeAllInstances(); }
