from autogen import AgentFlow

def ingest(file_path):
    return {"df": load_csv_to_df(file_path)}

def transform(df):
    try:
        return {"df": df.dropna().drop_duplicates()}
    except Exception as e:
        return {"error": str(e)}

def load(df):
    return {"success": upload_df_to_db(df)}

flow = AgentFlow()
flow.add_fn("ingest", ingest)
flow.add_fn("transform", transform)
flow.add_fn("load", load)

flow.set_flow([("ingest", "transform"), ("transform", "load")])

# Run: flow.execute({"file_path": "/tmp/source.csv"})