prefect_dbt.core.runner

Runner for dbt commands

Functions

execute_dbt_node ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L81" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

execute_dbt_node(task_state: NodeTaskTracker, node_id: str, asset_id: Union[str, None])

Execute a dbt node and wait for its completion.

This function will:

1. Set up the task logger
2. Wait for the node to finish using efficient threading.Event
3. Check the node's status and fail if it's in a failure state

Classes

PrefectDbtRunner ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L107" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

A runner for executing dbt commands with Prefect integration.

This class enables the invocation of dbt commands while integrating with Prefect's logging and assets capabilities.

Args:

• manifest: Optional pre-loaded dbt manifest
• settings: Optional PrefectDbtSettings instance for configuring dbt
• raise_on_failure: Whether to raise an error if the dbt command encounters a non-exception failure
• client: Optional Prefect client instance
• include_compiled_code: Whether to include compiled code in the asset description
• disable_assets: Global override for disabling asset generation for dbt nodes. If True, assets will not be created for any dbt nodes, even if the node's prefect config has enable_assets set to True.
• _force_nodes_as_tasks: Whether to force each dbt node execution to have a Prefect task representation when .invoke() is called outside of a flow or task run

Methods:

get_dbt_event_msg ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L564" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

get_dbt_event_msg(event: EventMsg) -> str

graph ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L194" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

graph(self) -> Graph

invoke ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L1142" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

invoke(self, args: list[str], **kwargs: Any)

Invokes a dbt command.

Supports the same arguments as dbtRunner.invoke(). https://docs.getdbt.com/reference/programmatic-invocations

Args:

• args: List of command line arguments
• **kwargs: Additional keyword arguments

Returns:

• The result of the dbt command invocation

log_level ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L183" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

log_level(self) -> EventLevel

manifest ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L187" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

manifest(self) -> Manifest

on_run_end ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/_hooks.py#L87" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

on_run_end(self, fn: F) -> F

on_run_start ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/_hooks.py#L75" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

on_run_start(self, fn: F) -> F

post_model ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/_hooks.py#L101" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

post_model(self, fn: F) -> F

profiles_dir ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L173" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

profiles_dir(self) -> Path

project_dir ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L178" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

project_dir(self) -> Path

project_name ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L201" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

project_name(self) -> str

target_path ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/integrations/prefect-dbt/prefect_dbt/core/runner.py#L168" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

target_path(self) -> Path