acoustic-carpenter-78188
09/12/2023, 1:06 AMfrom flytekit import workflow
from flytekitplugins.dbt.task import DBTRun, DBTRunInput
dbt_task = DBTRun(name="the_name_of_the_task")
@workflow
def my_wf() -> None:
input = DBTRunInput(
project_dir="dbt_project_dir",
profiles_dir="dbt_project_dir/docker-context",
profile="default",
select=["some_model"]
)
dbt_task(input=input)
Screenshots
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteacoustic-carpenter-78188
09/12/2023, 1:06 AM