增加并行框架
This commit is contained in:
6
pom.xml
6
pom.xml
@@ -51,6 +51,12 @@
|
||||
<groupId>net.datafaker</groupId>
|
||||
<artifactId>datafaker</artifactId>
|
||||
<version>2.4.2</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.yomahub</groupId>
|
||||
<artifactId>liteflow-spring-boot-starter</artifactId>
|
||||
<version>2.13.0</version>
|
||||
</dependency>
|
||||
<!--<dependency>
|
||||
<groupId>io.projectreactor.netty</groupId>
|
||||
|
||||
@@ -0,0 +1,21 @@
|
||||
package com.lanyuanxiaoyao.ai.analysis.flow;
|
||||
|
||||
import com.yomahub.liteflow.annotation.LiteflowComponent;
|
||||
import com.yomahub.liteflow.core.NodeComponent;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.ai.chat.client.ChatClient;
|
||||
|
||||
@Slf4j
|
||||
@LiteflowComponent
|
||||
public class ChartNode extends NodeComponent {
|
||||
private final ChatClient client;
|
||||
|
||||
public ChartNode(ChatClient.Builder builder) {
|
||||
this.client = builder.build();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void process() throws Exception {
|
||||
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user