<http://df.to|df.to>_dict(orient='records')

<http://df.to|df.to>_records()

In [15]: @task
    ...: def create():
    ...:     return pd.DataFrame({"a": [1, 2, 3], "b": [4, 5, 6]}).to_records()
    ...:
    ...:

In [16]: @task
    ...: def transform(row):
    ...:     return row.a + row.b
    ...:

In [17]: with Flow("test") as flow:
    ...:     data = create()
    ...:     res = transform.map(data)
    ...:

In [18]: flow.run()