
workflow.add_conditional_edges(
"Evaluator", router, {"continue": "Leader", "call_tool": "Tool"}
)
workflow.add_conditional_edges(
"Leader",
lambda x: x["next"],
{
"Programmer": "Programmer",
"TestWriter": "TestWriter",
"Evaluator": "Evaluator",
"Finish": END,
},
)
workflow.add_edge("Programmer", "Leader")
workflow.add_edge("TestWriter", "Leader")
workflow.add_edge("Tool", "Evaluator")
workflow.set_entry_point("Leader")
# ワークフローの実行
graph = workflow.compile()
with open("HumanEval.jsonl") as f:
lines = f.readlines()
entries = [json.loads(line) for line in lines]
entry = entries[0]
result = graph.invoke({"messages": [], "task": entry["prompt"]})
for message ...