Airflow中执行带--vars参数的dbt命令时YAML验证失败（含空格的字典值引发问题）

这种Airflow和本地命令行环境下的参数解析差异确实挺闹心的，我来帮你捋清楚怎么解决这个问题。

首先得搞明白问题根源：你在Git Bash里能正常运行，是因为bash会正确识别单引号包裹的内容作为一个整体参数；但Airflow在处理命令参数时，对引号和转义的逻辑不一样，导致带空格的reset query_group被拆成了两个参数，YAML解析到一半就报错了。

给你几个靠谱的解决方案，按推荐程度排序：

1. 用PythonOperator调用dbt（最稳妥） #

直接绕过命令行参数解析的坑，用Python的subprocess模块传递列表形式的参数，这样每个参数都会被完整传递，不会被空格拆分：

from airflow.operators.python import PythonOperator
import subprocess
import json

def run_dbt_task():
    # 先把要传递的变量写成字典，格式清晰不容易错
    dbt_vars = {
        "post_hook": "reset query_group",
        "whatever": "else"
    }
    # 转成JSON字符串（dbt的--vars支持JSON格式，和YAML兼容）
    vars_json = json.dumps(dbt_vars)
    
    # 用列表传递参数，shell=False避免解析问题
    subprocess.run(
        ["dbt", "run", "--vars", vars_json],
        check=True,
        shell=False,
        cwd="/path/to/your/dbt/project"  # 记得指定dbt项目路径
    )

# 在DAG里定义任务
dbt_run_task = PythonOperator(
    task_id="dbt_run",
    python_callable=run_dbt_task
)

2. 修正BashOperator的引号嵌套 #

如果坚持用BashOperator，一定要确保--vars的参数被完整包裹，避免Airflow拆分参数。正确的写法是外层用单引号，内层JSON用双引号，同时注意转义：

from airflow.operators.bash import BashOperator

dbt_run_task = BashOperator(
    task_id="dbt_run",
    # 外层单引号，内部双引号不需要转义；或者外层双引号，内部双引号用\转义
    bash_command='dbt run --vars \'{"post_hook": "reset query_group", "whatever": "else"}\'',
    cwd="/path/to/your/dbt/project"
)

这里要避开HTML转义的"，直接用原生引号，Airflow才能正确识别。

3. 用YAML块级语法传递变量 #

如果你习惯写YAML格式的变量，也可以用YAML的块字符串语法，把带空格的内容单独换行：

BashOperator(
    task_id="dbt_run",
    bash_command='dbt run --vars \'post_hook: |\n  reset query_group\nwhatever: else\'',
    cwd="/path/to/your/dbt/project"
)

这种写法里，|表示保留换行和空格，YAML解析器会把reset query_group当成完整的字符串值。

之前你尝试的写法没成功，大概率是因为用了HTML转义的"，Airflow没有把它解析成实际的引号，导致参数被错误拆分。换成本生引号或者用Python调用的方式，问题就能解决啦。

备注：内容来源于stack exchange，提问作者Krzysztof Dołęgowski