pipeline.src.flows.infractions

Functions

`extract_infractions`()
`clean_infractions`(infractions)
`load_infractions`(infractions)
`infractions_flow`()

Module Contents

pipeline.src.flows.infractions.extract_infractions()[source]

pipeline.src.flows.infractions.clean_infractions(infractions)[source]

pipeline.src.flows.infractions.load_infractions(infractions)[source]

pipeline.src.flows.infractions.infractions_flow()[source]