Pandas wrapper

Module for building dags using pandas.

PandasWrapper dataclass

Helper call for adding pandas Nodes to a Dag.

latest_by_keys(stream, keys)

Build a state of the latest row by keys.