Module pipelines.rj_smtr.br_rj_riodejaneiro_recursos.flows

Flows for br_rj_riodejaneiro_recurso

Functions

def table_params(tables, exclude)

Expand source code

lambda tables, exclude: (
    [t for t in tables if t["table_id"] not in exclude]
    if exclude is not None
    else tables
),

def wait_captura_false()

Expand source code

lambda: [None],

def wait_materializacao_false()

Expand source code

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

def wait_recaptura_false()

Expand source code

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