dbt
| Class |
Description |
DbtNodeResult |
Small serializable summary of one dbt node result. |
DbtTask |
A Flyte task that maps one dbtRunner.invoke(…) call to one task. |
DbtTaskResolver |
Reconstructs a DbtTask in the remote task container. |
| Exception |
Description |
DbtInvocationError |
Raised when dbt finishes cleanly but reports failed node results. |
| Method |
Description |
invoke_dbt() |
Run exactly one dbtRunner invocation and return a serializable summary. |
def invoke_dbt(
cli_args: list[str],
callbacks: Sequence[DbtEventCallback | str] | None = None,
) -> list[DbtNodeResult]
Run exactly one dbtRunner invocation and return a serializable summary.
| Parameter |
Type |
Description |
cli_args |
list[str] |
|
callbacks |
Sequence[DbtEventCallback | str] | None |
|
