diff --git a/langstream-agents/langstream-ai-agents/src/main/java/com/datastax/oss/streaming/ai/model/ComputeField.java b/langstream-agents/langstream-ai-agents/src/main/java/com/datastax/oss/streaming/ai/model/ComputeField.java index 4746c3400..2c5ce8309 100644 --- a/langstream-agents/langstream-ai-agents/src/main/java/com/datastax/oss/streaming/ai/model/ComputeField.java +++ b/langstream-agents/langstream-ai-agents/src/main/java/com/datastax/oss/streaming/ai/model/ComputeField.java @@ -16,7 +16,6 @@ package com.datastax.oss.streaming.ai.model; import ai.langstream.ai.agents.commons.jstl.JstlEvaluator; -import jakarta.el.ELException; import java.math.BigDecimal; import java.sql.Time; import java.sql.Timestamp; diff --git a/langstream-core/src/main/java/ai/langstream/impl/agents/ai/GenAIToolKitFunctionAgentProvider.java b/langstream-core/src/main/java/ai/langstream/impl/agents/ai/GenAIToolKitFunctionAgentProvider.java index 0322952bf..720509ed2 100644 --- a/langstream-core/src/main/java/ai/langstream/impl/agents/ai/GenAIToolKitFunctionAgentProvider.java +++ b/langstream-core/src/main/java/ai/langstream/impl/agents/ai/GenAIToolKitFunctionAgentProvider.java @@ -93,7 +93,10 @@ protected final ComponentType getComponentType(AgentConfiguration agentConfigura @Override protected Class getAgentConfigModelClass(String type) { StepConfigurationInitializer stepConfigurationInitializer = STEP_TYPES.get(type); - log.info("Validating agent configuration model for type {} with {}", type, stepConfigurationInitializer.getAgentConfigurationModelClass()); + log.info( + "Validating agent configuration model for type {} with {}", + type, + stepConfigurationInitializer.getAgentConfigurationModelClass()); return stepConfigurationInitializer.getAgentConfigurationModelClass(); } diff --git a/langstream-core/src/main/java/ai/langstream/impl/uti/ClassConfigValidator.java b/langstream-core/src/main/java/ai/langstream/impl/uti/ClassConfigValidator.java index 937e85ecd..403bd030d 100644 --- a/langstream-core/src/main/java/ai/langstream/impl/uti/ClassConfigValidator.java +++ b/langstream-core/src/main/java/ai/langstream/impl/uti/ClassConfigValidator.java @@ -319,11 +319,7 @@ private static void validateProperty( if (actualValue instanceof Collection collection) { for (Object o : collection) { validateProperty( - entityRef, - fullPropertyKey, - o, - propertyValue.getItems(), - propertyKey); + entityRef, fullPropertyKey, o, propertyValue.getItems(), propertyKey); } } else { validateProperty( diff --git a/langstream-k8s-runtime/langstream-k8s-runtime-core/src/test/java/ai/langstream/runtime/impl/k8s/GenAIAgentsTest.java b/langstream-k8s-runtime/langstream-k8s-runtime-core/src/test/java/ai/langstream/runtime/impl/k8s/GenAIAgentsTest.java index bae1d6ffa..8cd2b2949 100644 --- a/langstream-k8s-runtime/langstream-k8s-runtime-core/src/test/java/ai/langstream/runtime/impl/k8s/GenAIAgentsTest.java +++ b/langstream-k8s-runtime/langstream-k8s-runtime-core/src/test/java/ai/langstream/runtime/impl/k8s/GenAIAgentsTest.java @@ -843,7 +843,6 @@ public void testForceAiService() throws Exception { } } - @Test public void testValidateBadComputeStep() throws Exception { Application applicationInstance = @@ -871,15 +870,17 @@ public void testValidateBadComputeStep() throws Exception { .getApplication(); try (ApplicationDeployer deployer = - ApplicationDeployer.builder() - .registry(new ClusterRuntimeRegistry()) - .pluginsRegistry(new PluginsRegistry()) - .build()) { - Exception e = assertThrows(Exception.class, () -> { - deployer.createImplementation("app", applicationInstance); - }); + ApplicationDeployer.builder() + .registry(new ClusterRuntimeRegistry()) + .pluginsRegistry(new PluginsRegistry()) + .build()) { + Exception e = + assertThrows( + Exception.class, + () -> { + deployer.createImplementation("app", applicationInstance); + }); assertEquals("Function [fn:len] not found", e.getMessage()); - } } }