dbt prehook宏截断pub_table异常：版本2查询存在却不执行截断？

核心问题 #

在pub_table模型的prehook中调用截断宏时，版本2（使用dbt_utils.get_single_value判断表存在）的日志明确显示进入了TRUNCATE逻辑，但实际未截断表；而版本1（硬编码table_exists=1）则能正常截断。两个版本仅表存在判断的实现方式不同。

可能原因 #

1. 宏执行上下文干扰：dbt_utils.get_single_value会触发额外的元数据查询，这可能打乱dbt对prehook中DDL语句的渲染和执行流程。dbt在处理宏时，若插入额外查询，可能导致后续的TRUNCATE语句未被正确纳入执行批次。
2. dbt_utils.get_single_value的隐性行为：部分版本的该宏可能存在事务处理或结果类型转换的隐性逻辑，间接影响了后续DDL语句的执行。

解决办法 #

方案1：改用dbt内置的adapter.get_relation判断表存在（推荐） #

这是dbt官方推荐的表存在判断方式，无需查询系统表，更可靠且不会干扰执行上下文：

{% macro delete_existing_records(table_name, ref_table_name, max_meta_inserted_at) %}
    {% if execute %}
        {% set target_relation = adapter.get_relation(
            database=table_name.project,
            schema=table_name.dataset,
            identifier=table_name.name
        ) %}
        
        {% set table_exists = target_relation is not none %}
        
        {{ log("Table exists value: " ~ table_exists, info=True) }}
        
        {% if table_exists %}
            {{ log("Truncating table: " ~ table_name, info=True) }}
            TRUNCATE TABLE {{ table_name }}
        {% else %}
            {{ log("Table does not exist: " ~ table_name, info=True) }}
        {% endif %}
    {% endif %}
{% endmacro %}

方案2：手动执行查询获取结果，避免依赖dbt_utils.get_single_value #

直接用adapter.execute执行元数据查询并处理结果，减少第三方宏的隐性影响：

{% macro delete_existing_records(table_name, ref_table_name, max_meta_inserted_at) %}
    {% if execute %}
        {% set table_exists_query %}
            SELECT COUNT(*) 
            FROM `{{ table_name.project }}.{{ table_name.dataset }}.__TABLES__`
            WHERE table_id = '{{ table_name.name }}'
        {% endset %}
            
        {% set results = adapter.execute(table_exists_query) %}
        {% set table_exists = results.rows[0][0] | int %}
        
        {{ log("Table exists value: " ~ table_exists, info=True) }}
        
        {% if table_exists > 0 %}
            {{ log("Truncating table: " ~ table_name, info=True) }}
            TRUNCATE TABLE {{ table_name }}
        {% else %}
            {{ log("Table does not exist: " ~ table_name, info=True) }}
        {% endif %}
    {% endif %}
{% endmacro %}

方案3：检查并升级dbt_utils版本 #

若坚持使用dbt_utils.get_single_value，可升级到最新稳定版，排查是否存在该宏的已知bug导致执行异常。

为什么版本1能正常工作？ #

版本1未触发任何额外查询，宏直接渲染出TRUNCATE语句，prehook的执行流程未被干扰，DDL语句能被dbt正常发送到数据库执行；而版本2中额外的元数据查询打破了这个流程，导致TRUNCATE语句未被实际执行。

内容的提问来源于stack exchange，提问作者fancybear