Skip to content

Commit

Permalink
style
Browse files Browse the repository at this point in the history
  • Loading branch information
eolivelli committed Dec 14, 2023
1 parent 5b75a6b commit ff7bbe7
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -843,7 +843,6 @@ public void testForceAiService() throws Exception {
}
}


@Test
public void testValidateBadComputeStep() throws Exception {
Application applicationInstance =
Expand Down Expand Up @@ -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());

}
}
}

0 comments on commit ff7bbe7

Please sign in to comment.