This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch fix-default-asset-migration in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 29cc975e61f0c149accc15ba96d8fd5615cdc8d9 Author: Dominik Riemer <[email protected]> AuthorDate: Mon Nov 24 14:27:04 2025 +0100 fix: Use assert storage for default asset migration --- .../manager/setup/tasks/CreateDefaultAssetTask.java | 8 +------- .../core/migrations/v070/CreateDefaultAssetMigration.java | 10 ++-------- 2 files changed, 3 insertions(+), 15 deletions(-) diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java index 0e1fa185fe..16763ab789 100644 --- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java +++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java @@ -22,8 +22,6 @@ import org.apache.streampipes.commons.constants.GenericDocTypes; import org.apache.streampipes.model.assets.SpAssetModel; import org.apache.streampipes.storage.management.StorageDispatcher; -import java.io.IOException; - public class CreateDefaultAssetTask implements InstallationTask { @Override @@ -34,10 +32,6 @@ public class CreateDefaultAssetTask implements InstallationTask { asset.setAssetName("Default Asset"); asset.setRemovable(true); - try { - StorageDispatcher.INSTANCE.getNoSqlStore().getGenericStorage().create(asset, SpAssetModel.class); - } catch (IOException e) { - e.printStackTrace(); - } + StorageDispatcher.INSTANCE.getNoSqlStore().getAssetStorage().persist(asset); } } diff --git a/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateDefaultAssetMigration.java b/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateDefaultAssetMigration.java index 0a96f2310d..0eab481999 100644 --- a/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateDefaultAssetMigration.java +++ b/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateDefaultAssetMigration.java @@ -24,18 +24,12 @@ import org.apache.streampipes.manager.setup.tasks.CreateDefaultAssetTask; import org.apache.streampipes.service.core.migrations.Migration; import org.apache.streampipes.storage.management.StorageDispatcher; -import java.io.IOException; - public class CreateDefaultAssetMigration implements Migration { @Override public boolean shouldExecute() { - try { - return StorageDispatcher.INSTANCE.getNoSqlStore().getGenericStorage() - .findOne(GenericDocTypes.DEFAULT_ASSET_DOC_ID) == null; - } catch (IOException e) { - return true; - } + return StorageDispatcher.INSTANCE.getNoSqlStore().getAssetStorage() + .getElementById(GenericDocTypes.DEFAULT_ASSET_DOC_ID) == null; } @Override
