spotless

vectorize-io · Aug 22, 2024 · 93eedb2 · 93eedb2
1 parent 3a765a6
commit 93eedb2
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/langstream-core/src/main/java/ai/langstream/impl/deploy/ApplicationDeployer.java b/langstream-core/src/main/java/ai/langstream/impl/deploy/ApplicationDeployer.java
@@ -107,7 +107,8 @@ private void setupAssets(
         try {
             for (AssetNode assetNode : executionPlan.getAssets()) {
                 AssetDefinition asset =
-                        ObjectMapperFactory.getDefaultMapper().convertValue(assetNode.config(), AssetDefinition.class);
+                        ObjectMapperFactory.getDefaultMapper()
+                                .convertValue(assetNode.config(), AssetDefinition.class);
                 try {
                     boolean created = setupAsset(asset, assetManagerRegistry);
                     if (created) {
@@ -238,7 +239,9 @@ private static SimpleRecord createAssetEventRecord(
                         .category(EventRecord.Categories.Asset)
                         .type(eventType)
                         .timestamp(System.currentTimeMillis())
-                        .source(ObjectMapperFactory.getDefaultMapper().convertValue(source, Map.class))
+                        .source(
+                                ObjectMapperFactory.getDefaultMapper()
+                                        .convertValue(source, Map.class))
                         .data(data)
                         .build();
 
@@ -406,7 +409,8 @@ private void cleanupAssets(
         try {
             for (AssetNode assetNode : executionPlan.getAssets()) {
                 AssetDefinition asset =
-                        ObjectMapperFactory.getDefaultMapper().convertValue(assetNode.config(), AssetDefinition.class);
+                        ObjectMapperFactory.getDefaultMapper()
+                                .convertValue(assetNode.config(), AssetDefinition.class);
                 try {
                     boolean deleted = cleanupAsset(asset);
                     if (deleted) {

diff --git a/...am-runtime/langstream-runtime-impl/src/test/java/ai/langstream/assets/DeployAssetsIT.java b/...am-runtime/langstream-runtime-impl/src/test/java/ai/langstream/assets/DeployAssetsIT.java
@@ -155,7 +155,8 @@ public void accept(Object o) {
                                     assertEquals(
                                             "{\"tenant\":\"tenant\",\"applicationId\":\"app\",\"asset\":{\"id\":\"my-table\",\"name\":\"my-table\",\"config\":{\"datasource\":{\"configuration\":{\"service\":\"jdbc\",\"driverClass\":\"org.postgresql.Driver\",\"url\":\"bar\"}},\"table\":\"my-table\"},\"creation-mode\":\"create-if-not-exists\",\"deletion-mode\":\"delete\",\"asset-type\":\"mock-database-resource\",\"events-topic\":\"%s\"}}"
                                                     .formatted(eventsTopic),
-                                            ObjectMapperFactory.getDefaultMapper().writeValueAsString(read.get("source")));
+                                            ObjectMapperFactory.getDefaultMapper()
+                                                    .writeValueAsString(read.get("source")));
                                     assertNotNull(read.get("timestamp"));
                                 }
                             }));
@@ -233,13 +234,16 @@ public void testDeployAssetFailed() throws Exception {
                                 @SneakyThrows
                                 public void accept(Object o) {
                                     log.info("Received: {}", o);
-                                    Map read = ObjectMapperFactory.getDefaultMapper().readValue((String) o, Map.class);
+                                    Map read =
+                                            ObjectMapperFactory.getDefaultMapper()
+                                                    .readValue((String) o, Map.class);
                                     assertEquals("AssetCreationFailed", read.get("type"));
                                     assertEquals("Asset", read.get("category"));
                                     assertEquals(
                                             "{\"tenant\":\"tenant\",\"applicationId\":\"app\",\"asset\":{\"id\":\"my-table\",\"name\":\"my-table\",\"config\":{\"fail\":true,\"datasource\":{\"configuration\":{\"service\":\"jdbc\",\"driverClass\":\"org.postgresql.Driver\",\"url\":\"bar\"}}},\"creation-mode\":\"create-if-not-exists\",\"deletion-mode\":\"delete\",\"asset-type\":\"mock-database-resource\",\"events-topic\":\"%s\"}}"
                                                     .formatted(eventsTopic),
-                                            ObjectMapperFactory.getDefaultMapper().writeValueAsString(read.get("source")));
+                                            ObjectMapperFactory.getDefaultMapper()
+                                                    .writeValueAsString(read.get("source")));
                                     assertEquals(
                                             "Mock failure to deploy asset",
                                             ((Map<String, Object>) read.get("data"))