pipeline.src.flows.refresh_materialized_view

Functions

refresh_view(→ pandas.DataFrame)

refresh_materialized_view_flow(view_name[, schema])

Module Contents

pipeline.src.flows.refresh_materialized_view.refresh_view(view: sqlalchemy.Table) → pandas.DataFrame[source]
pipeline.src.flows.refresh_materialized_view.refresh_materialized_view_flow(view_name: str, schema: str = 'public')[source]