Mark
10/10/2022, 1:28 PMfrom prefect import flow
from prefect_dbt.cli.credentials import DbtCliProfile
from prefect_dbt.cli.commands import trigger_dbt_cli_command
@flow
def trigger_dbt_cli_commands_flow():
dbt_cli_profile = DbtCliProfile.load("dbtbase")
trigger_kwargs = dict(
profiles_dir="../dbt/data-dbt",
project_dir="../dbt/data-dbt/dbt-project/",
overwrite_profiles=False,
dbt_cli_profile=dbt_cli_profile,
)
trigger_dbt_cli_command(
"dbt deps",
**trigger_kwargs
)
return result
trigger_dbt_cli_commands_flow()
José Duarte
10/10/2022, 2:41 PMMark
10/10/2022, 2:49 PMJosé Duarte
10/10/2022, 2:51 PMprofiles_dir=config.DBT_PROFILES_DIR_PATH,
Mark
10/10/2022, 2:53 PMJosé Duarte
10/10/2022, 2:53 PMMark
10/10/2022, 2:54 PMJosé Duarte
10/10/2022, 2:55 PMJeff Hale
10/10/2022, 3:01 PM