diff --git a/opposites_attract.py b/opposites_attract.py index 4f993f6..414d404 100644 --- a/opposites_attract.py +++ b/opposites_attract.py @@ -324,7 +324,26 @@ async def output_node(state): print(f"\n[DEBUG][output] Ausgabe beendet.") return {"final_message": output_text} - +# ---------- LangGraph Graph ---------- +graph = StateGraph(state_schema=EmpathyState) +graph.add_node("sache_node", sache_node) +graph.add_node("selbst_node", selbst_node) +graph.add_node("beziehung_node", beziehung_node) +graph.add_node("appell_node", appell_node) +graph.add_node("psychoanalysis_node", psychoanalysis_node) +graph.add_node("output_node", output_node) +graph.add_edge(START, "sache_node") +graph.add_edge(START, "selbst_node") +graph.add_edge(START, "beziehung_node") +graph.add_edge(START, "appell_node") +graph.add_edge(START, "psychoanalysis_node") +graph.add_edge("sache_node", "output_node") +graph.add_edge("selbst_node", "output_node") +graph.add_edge("beziehung_node", "output_node") +graph.add_edge("appell_node", "output_node") +graph.add_edge("psychoanalysis_node", "output_node") +graph.add_edge("output_node", END) +app = graph.compile() # ---------- Ausführung ---------- async def main():