test/agents-flex
1
0
Fork 0
mirror of https://gitee.com/agents-flex/agents-flex.git synced 2024-11-29 18:38:17 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: rename "SleepUtils" to "SleepUtil"

Browse Source
This commit is contained in:
Michael Yang 2024-10-26 15:01:40 +08:00
parent 0f625489ec
commit e843a15999
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
agents-flex-core/src/main/java/com/agentsflex/core/util/SleepUtils.java → agents-flex-core/src/main/java/com/agentsflex/core/util/SleepUtil.java
View File

@ -17,7 +17,7 @@ package com.agentsflex.core.util;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
public class SleepUtils { public class SleepUtil {
public static void sleep(long millis) { public static void sleep(long millis) {
try { try {

4
agents-flex-llm/agents-flex-llm-spark/src/main/java/com/agentsflex/llm/spark/SparkLlm.java
View File

@ -32,7 +32,7 @@ import com.agentsflex.core.parser.AiMessageParser;
import com.agentsflex.core.parser.FunctionMessageParser; import com.agentsflex.core.parser.FunctionMessageParser;
import com.agentsflex.core.prompt.Prompt; import com.agentsflex.core.prompt.Prompt;
import com.agentsflex.core.store.VectorData; import com.agentsflex.core.store.VectorData;
import com.agentsflex.core.util.SleepUtils; import com.agentsflex.core.util.SleepUtil;
import com.agentsflex.core.util.StringUtil; import com.agentsflex.core.util.StringUtil;
import com.alibaba.fastjson.JSONPath; import com.alibaba.fastjson.JSONPath;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -78,7 +78,7 @@ public class SparkLlm extends BaseLlm<SparkLlmConfig> {
if (code != 0) { if (code != 0) {
//11202 授权错误：秒级流控超限。秒级并发超过授权路数限制 //11202 授权错误：秒级流控超限。秒级并发超过授权路数限制
if (code.equals(11202) && tryTimes < 3) { if (code.equals(11202) && tryTimes < 3) {
SleepUtils.sleep(200); SleepUtil.sleep(200);
return embed(document, options, tryTimes + 1); return embed(document, options, tryTimes + 1);
} else { } else {
logger.error(resp); logger.error(resp);