2.12.4
dbt
Directory
Classes
| 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. |
Errors
| Exception | Description |
|---|---|
DbtInvocationError |
Raised when dbt finishes cleanly but reports failed node results. |
Methods
| Method | Description |
|---|---|
invoke_dbt() |
Run exactly one dbtRunner invocation and return a serializable summary. |
Methods
invoke_dbt()
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 |