martin o leary
06/02/2023, 9:38 AMrex
06/02/2023, 2:11 PMdagster-dbt
API revamp! Check out the proposal here.
Rather than specifying the op_name
, you can just specify the name of the function 🙂
@dbt_assets(manifest=manifest)
def my_custom_name(context: OpExecutionContext, dbt: DbtCli):
yield from dbt.cli(["run"], manifest=manifest, context=context).stream()
This is the equivalent of using op_name="my_custom_name"