Module pipelines.rj_smtr.br_rj_riodejaneiro_gtfs.flows

Flows for gtfs

Functions

def wait_captura_false()

Expand source code

lambda: [None], checkpoint=False, name="assign_none_to_previous_runs"