Andreas Nord
from prefect import task, flow, get_run_logger from dbt.cli.main import dbtRunner, dbtRunnerResult @task def dbt_run(project_dir: str, target: str): runner = dbtRunner() result = runner.invoke( ["run", "--project-dir", project_dir, "--profiles-dir", project_dir, "--target", target])
Sean Williams
@flow def trigger_dbt_flow() -> str: result = DbtCoreOperation( commands=["pwd", "dbt debug", "dbt run"], project_dir="your_project", profiles_dir="~/.dbt" ).run() return result
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.