graph = langgraph.Graph() graph.add_node(ToolNode(func=lambda inp: {"df": load_csv_to_df(inp["file_path"])}), inputs=["file_path"]) graph.add_node(ToolNode(func=lambda inp: {"df": inp["df"][inp["df"]["payment_id"].notnull()]}), inputs=["df"]) graph.add_node(ToolNode(func=lambda inp: {"success": upload_df_to_db(inp["df"])}), inputs=["df"]) graph.add_edge("ToolNode_1", "ToolNode_2") graph.add_edge("ToolNode_2", "ToolNode_3") graph.compile("file_path") result = graph.run({"file_path": "/data/orders.csv"})