pipeline.src.flows.trips_snapshot

Functions

extract_trips_snapshot(→ pandas.DataFrame)
load_trips_snapshot(trips)
trips_snapshot_flow()

Module Contents

pipeline.src.flows.trips_snapshot.extract_trips_snapshot() → pandas.DataFrame

pipeline.src.flows.trips_snapshot.load_trips_snapshot(trips: pandas.DataFrame)

pipeline.src.flows.trips_snapshot.trips_snapshot_flow()