Prefect + Dbt
Plug Prefect into your dbt stack to gain further coordination between dbt models and their upstream and downstream dependencies.
1@flow
2def trigger_dbt_flow():
3 dbt_cli_profile = DbtCliProfile.load("DBT-CORE-OPERATION-BLOCK-NAME-PLACEHOLDER")
4 with DbtCoreOperation(
5 commands=["dbt debug", "dbt run"],
6 project_dir="PROJECT-DIRECTORY-PLACEHOLDER",
7 profiles_dir="PROFILES-DIRECTORY-PLACEHOLDER",
8 dbt_cli_profile=dbt_cli_profile,
9 ) as dbt_operation:
10 dbt_process = dbt_op.trigger()
11 dbt_process.wait_for_completion()
12 result = dbt_process.fetch_result()
13 return result
14Keep dbt models in sync with other popular integrations
Run a dbt model with an ETL sync
Lorem ipsum dolor sit amet, consectetur adipiscing elit
run a notebook after dbt model has been updated
Lorem ipsum dolor sit amet, consectetur adipiscing elit