Madison Schott
08/17/2021, 5:08 PMname=""
suggested in the documentation isn't working for the format I have my tasks in
campaign_details_dbt_run = dbt_task(name="Campaign Details", command='dbt run -m campaign_details')
Madison Schott
08/17/2021, 5:09 PMdbt_task = DbtShellTask())
Kevin Kho
dbt_task = DbtShellTask(name="...")
Madison Schott
08/17/2021, 5:16 PMKevin Kho
task run name
based on inputs like this ? But for the actual task name, I don’t think so. You could have DbtShellTask in your flow code like this:
with Flow(...) as flow:
a = DbtShellTask(name=...)(cmd=...)
b = DbtShellTask(name=...)(cmd=...)
Madison Schott
08/17/2021, 5:33 PMMadison Schott
08/17/2021, 5:37 PMKevin Kho
a = DbtShellTask(all_the_kwargs)
b = a
b.name = xxx
c = a
c.name = xxx
with Flow(...) as flow:
a = DbtShellTask(name=...)(cmd=...)
b = DbtShellTask(name=...)(cmd=...)
or maybe
dict_of_kwargs = {...}
a = DbtShellTask(**dict_of_kwargs)
dict_of_kwargs['name'] = xxx
b = DbtShellTask(**dict_of_kwargs)
with Flow(...) as flow:
a = a(cmd=...)
b = b(cmd=...)
Chris White
campaign_details_dbt_run = dbt_task(task_args={"name": "Campaign Details"}, command='dbt run -m campaign_details')
the special keyword task_args
allows you to override init kwargs (which includes name
) when you call the taskMadison Schott
08/17/2021, 6:21 PM