flow = AgentFlow()
flow.add_fn("ingest", lambda file_path: {"df": load_csv_to_df(file_path)})
flow.add_fn("filter", lambda df: {"df": df[df["payment_id"].notnull()]})
flow.add_fn("load", lambda df: {"success": upload_df_to_db(df)})

flow.set_flow([("ingest", "filter"), ("filter", "load")])
flow.execute({"file_path": "/data/orders.csv"})