from prefect import Flow
from prefect.tasks.dbt import DbtShellTask
with Flow(name="dbt_flow") as f:
task = DbtShellTask(
profile_name="profile name",
environment='dev',
dbt_kwargs={
"type": "snowflake",
"account": "account name",
"user": "username",
"authentictor": "externalbrowser", # tried password as well on other acct, same error
"role": "role name",
"warehouse": "wh name",
"database": "db name"
"schema": "schema name",
"threads": 4,
"client_session_keep_alive": True,
},
overwrite_profiles=True,
profiles_dir= r"C:\Users\jabduljabbar\.dbt"
)(command='dbt run')
out = f.run()