Skip to content

Commit 3f6a59d

Browse files
authored
[Fix #869] Splitting ExpressionFactory from ModelFactory (#870)
Signed-off-by: fjtirado <ftirados@redhat.com>
1 parent f4efa05 commit 3f6a59d

File tree

42 files changed

+291
-111
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+291
-111
lines changed

experimental/agentic/pom.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,10 @@
1111
<dependency>
1212
<groupId>io.serverlessworkflow</groupId>
1313
<artifactId>serverlessworkflow-experimental-lambda</artifactId>
14+
</dependency>
15+
<dependency>
16+
<groupId>io.serverlessworkflow</groupId>
17+
<artifactId>serverlessworkflow-experimental-model</artifactId>
1418
</dependency>
1519
<dependency>
1620
<groupId>dev.langchain4j</groupId>

experimental/agentic/src/main/java/io/serverlessworkflow/impl/expressions/agentic/AgenticExpressionFactory.java

Lines changed: 0 additions & 33 deletions
This file was deleted.
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,11 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.serverlessworkflow.impl.expressions.agentic;
16+
package io.serverlessworkflow.impl.model.agentic;
1717

1818
import dev.langchain4j.agentic.scope.AgenticScope;
1919
import io.serverlessworkflow.impl.WorkflowModel;
20-
import io.serverlessworkflow.impl.expressions.func.JavaModel;
20+
import io.serverlessworkflow.impl.model.func.JavaModel;
2121
import java.util.Collection;
2222
import java.util.Map;
2323
import java.util.Optional;
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,12 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.serverlessworkflow.impl.expressions.agentic;
16+
package io.serverlessworkflow.impl.model.agentic;
1717

1818
import dev.langchain4j.agentic.scope.AgenticScope;
1919
import dev.langchain4j.agentic.scope.ResultWithAgenticScope;
2020
import io.serverlessworkflow.impl.WorkflowModel;
21-
import io.serverlessworkflow.impl.expressions.func.JavaModelCollection;
21+
import io.serverlessworkflow.impl.model.func.JavaModelCollection;
2222
import java.util.Collections;
2323
import java.util.Map;
2424
import java.util.Optional;
Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,20 +13,20 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.serverlessworkflow.impl.expressions.agentic;
16+
package io.serverlessworkflow.impl.model.agentic;
1717

1818
import dev.langchain4j.agentic.scope.AgenticScope;
1919
import io.cloudevents.CloudEvent;
2020
import io.cloudevents.CloudEventData;
2121
import io.serverlessworkflow.impl.WorkflowModel;
2222
import io.serverlessworkflow.impl.WorkflowModelCollection;
2323
import io.serverlessworkflow.impl.WorkflowModelFactory;
24-
import io.serverlessworkflow.impl.expressions.agentic.langchain4j.AgenticScopeRegistryAssessor;
24+
import io.serverlessworkflow.impl.model.agentic.langchain4j.AgenticScopeRegistryAssessor;
2525
import java.time.OffsetDateTime;
2626
import java.util.HashMap;
2727
import java.util.Map;
2828

29-
class AgenticModelFactory implements WorkflowModelFactory {
29+
public class AgenticModelFactory implements WorkflowModelFactory {
3030

3131
static final String DEFAULT_AGENTIC_SCOPE_STATE_KEY = "input";
3232
private final AgenticScopeRegistryAssessor scopeRegistryAssessor =
@@ -126,4 +126,11 @@ public WorkflowModel fromOther(Object value) {
126126
}
127127
return newAgenticModel(value);
128128
}
129+
130+
public AgenticModelFactory() {}
131+
132+
@Override
133+
public int priority() {
134+
return DEFAULT_PRIORITY - 1;
135+
}
129136
}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.serverlessworkflow.impl.expressions.agentic;
16+
package io.serverlessworkflow.impl.model.agentic;
1717

1818
import com.fasterxml.jackson.core.type.TypeReference;
1919
import com.fasterxml.jackson.databind.ObjectMapper;
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.serverlessworkflow.impl.expressions.agentic.langchain4j;
16+
package io.serverlessworkflow.impl.model.agentic.langchain4j;
1717

1818
import dev.langchain4j.agentic.internal.AgenticScopeOwner;
1919
import dev.langchain4j.agentic.scope.AgenticScope;
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
io.serverlessworkflow.impl.model.agentic.AgenticModelFactory

experimental/agentic/src/main/resources/META-INF/services/io.serverlessworkflow.impl.expressions.ExpressionFactory

Lines changed: 0 additions & 1 deletion
This file was deleted.

experimental/fluent/agentic-langchain4j/src/main/java/io/serverlessworkflow/fluent/agentic/langchain4j/WorkflowInvocationHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import dev.langchain4j.service.MemoryId;
2828
import io.serverlessworkflow.api.types.Workflow;
2929
import io.serverlessworkflow.impl.WorkflowApplication;
30-
import io.serverlessworkflow.impl.expressions.agentic.langchain4j.AgenticScopeRegistryAssessor;
30+
import io.serverlessworkflow.impl.model.agentic.langchain4j.AgenticScopeRegistryAssessor;
3131
import java.lang.reflect.InvocationHandler;
3232
import java.lang.reflect.Method;
3333
import java.lang.reflect.Parameter;

0 commit comments

Comments
 (0)