reject 选项，该选项通过抛出错误来拒绝图的新运行，并继续执行原始运行直至完成。下面是使用 reject 选项的一个快速示例。
设置
首先，我们将定义一个用于打印 JS 和 cURL 模型输出的辅助函数（如果您使用 Python，可以跳过此步骤）：- Javascript
- cURL
function prettyPrint(m) {
const padded = " " + m['type'] + " ";
const sepLen = Math.floor((80 - padded.length) / 2);
const sep = "=".repeat(sepLen);
const secondSep = sep + (padded.length % 2 ? "=" : "");
console.log(`${sep}${padded}${secondSep}`);
console.log("\n\n");
console.log(m.content);
}
# PLACE THIS IN A FILE CALLED pretty_print.sh
pretty_print() {
local type="$1"
local content="$2"
local padded=" $type "
local total_width=80
local sep_len=$(( (total_width - ${#padded}) / 2 ))
local sep=$(printf '=%.0s' $(eval "echo {1.."${sep_len}"}"))
local second_sep=$sep
if (( (total_width - ${#padded}) % 2 )); then
second_sep="${second_sep}="
fi
echo "${sep}${padded}${second_sep}"
echo
echo "$content"
}
- Python
- Javascript
- cURL
import httpx
from langchain_core.messages import convert_to_messages
from langgraph_sdk import get_client
client = get_client(url=<DEPLOYMENT_URL>)
# 使用名为 "agent" 部署的图
assistant_id = "agent"
thread = await client.threads.create()
import { Client } from "@langchain/langgraph-sdk";
const client = new Client({ apiUrl: <DEPLOYMENT_URL> });
// 使用名为 "agent" 部署的图
const assistantId = "agent";
const thread = await client.threads.create();
curl --request POST \
--url <DEPLOYMENT_URL>/threads \
--header 'Content-Type: application/json' \
--data '{}'
创建运行
现在我们可以运行一个线程，并尝试使用“reject”选项运行第二个，由于我们已经启动了一个运行，这应该会失败：- Python
- Javascript
- cURL
run = await client.runs.create(
thread["thread_id"],
assistant_id,
input={"messages": [{"role": "user", "content": "what's the weather in sf?"}]},
)
try:
await client.runs.create(
thread["thread_id"],
assistant_id,
input={
"messages": [{"role": "user", "content": "what's the weather in nyc?"}]
},
multitask_strategy="reject",
)
except httpx.HTTPStatusError as e:
print("无法启动并发运行", e)
const run = await client.runs.create(
thread["thread_id"],
assistantId,
input={"messages": [{"role": "user", "content": "what's the weather in sf?"}]},
);
try {
await client.runs.create(
thread["thread_id"],
assistantId,
{
input: {"messages": [{"role": "user", "content": "what's the weather in nyc?"}]},
multitask_strategy:"reject"
},
);
} catch (e) {
console.error("无法启动并发运行", e);
}
curl --request POST \
--url <DEPLOY<ENT_URL>>/threads/<THREAD_ID>/runs \
--header 'Content-Type: application/json' \
--data "{
\"assistant_id\": \"agent\",
\"input\": {\"messages\": [{\"role\": \"human\", \"content\": \"what\'s the weather in sf?\"}]},
}" && curl --request POST \
--url <DEPLOY<ENT_URL>>/threads/<THREAD_ID>/runs \
--header 'Content-Type: application/json' \
--data "{
\"assistant_id\": \"agent\",
\"input\": {\"messages\": [{\"role\": \"human\", \"content\": \"what\'s the weather in nyc?\"}]},
\"multitask_strategy\": \"reject\"
}" || { echo "无法启动并发运行"; echo "错误: $?" >&2; }
无法启动并发运行 Client error '409 Conflict' for url 'http://localhost:8123/threads/f9e7088b-8028-4e5c-88d2-9cc9a2870e50/runs'
更多信息请查看：https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/409
查看运行结果
我们可以验证原始线程已执行完成：- Python
- Javascript
- cURL
# 等待原始运行完成
await client.runs.join(thread["thread_id"], run["run_id"])
state = await client.threads.get_state(thread["thread_id"])
for m in convert_to_messages(state["values"]["messages"]):
m.pretty_print()
await client.runs.join(thread["thread_id"], run["run_id"]);
const state = await client.threads.getState(thread["thread_id"]);
for (const m of state["values"]["messages"]) {
prettyPrint(m);
}
source pretty_print.sh && curl --request GET \
--url <DEPLOYMENT_URL>/threads/<THREAD_ID>/runs/<RUN_ID>/join && \
curl --request GET --url <DEPLOYMENT_URL>/threads/<THREAD_ID>/state | \
jq -c '.values.messages[]' | while read -r element; do
type=$(echo "$element" | jq -r '.type')
content=$(echo "$element" | jq -r '.content | if type == "array" then tostring else . end')
pretty_print "$type" "$content"
done
================================ Human Message =================================
旧金山的天气怎么样？
================================== Ai Message ==================================
[{'id': 'toolu_01CyewEifV2Kmi7EFKHbMDr1', 'input': {'query': 'weather in san francisco'}, 'name': 'tavily_search_results_json', 'type': 'tool_use'}]
工具调用:
tavily_search_results_json (toolu_01CyewEifV2Kmi7EFKHbMDr1)
调用 ID: toolu_01CyewEifV2Kmi7EFKHbMDr1
参数:
query: weather in san francisco
================================= Tool Message =================================
Name: tavily_search_results_json
[{"url": "https://www.accuweather.com/en/us/san-francisco/94103/june-weather/347629", "content": "获取旧金山，加利福尼亚州的月度天气预报，包括每日最高/最低温、历史平均值，以帮助您提前规划。"}]
================================== Ai Message ==================================
根据 Tavily 的搜索结果，旧金山当前的天气是：
旧金山六月的平均最高气温约为 65°F (18°C)，平均最低气温约为 54°F (12°C)。由于夏季月份经常笼罩城市的海雾层，六月往往是旧金山较凉爽和多雾的月份之一。
关于旧金山典型六月天气的一些要点：
* 温和的气温，最高在 60 多华氏度，最低在 50 多华氏度
* 多雾的早晨，通常会在下午放晴
* 降雨很少或没有，因为六月处于旱季
* 多风的天气，风来自太平洋
* 建议穿着分层衣物以应对变化的天气条件
总之，您可以在一年中的这个时候在旧金山期待温和、多雾的早晨，随后是晴朗但凉爽的下午。海雾层使得气温相比加利福尼亚州其他地区在六月份保持温和。
Connect these docs to Claude, VSCode, and more via MCP for real-time answers.