ingest = IngestAgent()
filter_null = Agent(lambda df: {"df": df[df["payment_id"].notnull()]})
load = LoadAgent()

t1 = Task(ingest, ["file_path"])
t2 = Task(filter_null, ["df"])
t3 = Task(load, ["df"])

crew = Crew([t1, t2, t3])
crew.setup_dependencies([(t1, t2), (t2, t3)])

crew.run({"file_path": "/data/orders.csv"})