rithy
12/19/2024, 4:05 PMfrom prefect_dbt.cli import DbtCliProfile, DbtCoreOperation
from prefect import flow
@flow
def trigger_dbt_flow() -> str:
# Load the DbtCliProfile from a valid source
dbt_cli_profile = DbtCliProfile.load("dbt_block")
result = DbtCoreOperation(
commands=["pwd", "dbt debug", "dbt run"],
project_dir="PROJECT-DIRECTORY-PLACEHOLDER",
profiles_dir="PROFILES-DIRECTORY-PLACEHOLDER",
dbt_cli_profile=dbt_cli_profile
).run()
return result
if name == "__main__":
trigger_dbt_flow()
https://docs.prefect.io/integrations/prefect-dbt/index
I check the link above but not sure how to config . what should I add in dbt_block?