dbt-Snowflake VALIDATE函数与宏报错求助：无效Job UUID参数

问题排查与修复 #

核心问题 #

宏log_error_validate未返回有效JOB_ID，导致生成的SQL中JOB_ID => 参数为空，触发Snowflake VALIDATE函数的常量参数校验错误。主要问题点及修复如下：

1. 修正结果集索引错误 #

你的宏中用row[1]获取QUERY_ID，但查询仅返回QUERY_ID一列，Snowflake结果集索引从0开始，row[1]会取到空值。直接修改索引为row[0]：

{% if execute %}
    {% for row in results.rows %}
        {% set retval = row[0] %}
        {{ return(retval) }}
    {% endfor %}
{% endif %}

2. 处理无匹配COPY任务的边界情况 #

如果查询历史中找不到符合条件的COPY任务，宏会返回空值，依然触发报错。添加空结果判断并抛出明确提示：

{% if execute %}
    {% if results.rows | length > 0 %}
        {% set retval = results.rows[0][0] %}
        {{ return(retval) }}
    {% else %}
        {{ exceptions.raise_compiler_error("未找到符合条件的COPY任务，请检查查询过滤条件或执行历史") }}
    {% endif %}
{% endif %}

3. 优化查询过滤条件 #

原宏中使用LIKE匹配库、 schema名称，若无需模糊匹配，改用=提升准确性，避免因模糊匹配规则导致漏查：

WHERE 
    DATABASE_NAME = 'DB_NAME' 
    AND SCHEMA_NAME = 'SCHEMA_NAME' 
    AND QUERY_TYPE = 'COPY' 

同时确认WAREHOUSE_NAME => 'WH_NAME'中的仓库名称与实际环境一致。

修复后的完整宏代码 #

{% macro log_error_validate() %}
    {% set query_id %}
        SELECT QUERY_ID 
        FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY_BY_WAREHOUSE(WAREHOUSE_NAME => 'WH_NAME')) 
        WHERE 
            DATABASE_NAME = 'DB_NAME' 
            AND SCHEMA_NAME = 'SCHEMA_NAME' 
            AND QUERY_TYPE = 'COPY' 
        ORDER BY START_TIME DESC 
        LIMIT 1
    {% endset %}
 
    {% set results = run_query(query_id) %}

    {% if execute %}
        {% if results.rows | length > 0 %}
            {{ return(results.rows[0][0]) }}
        {% else %}
            {{ exceptions.raise_compiler_error("未找到目标COPY任务的查询记录，请检查过滤条件或执行历史") }}
        {% endif %}
    {% endif %}
{% endmacro %}

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