Airflow中Bash脚本else代码块失效问题排查

你的脚本存在三个关键问题，导致无法达到预期效果：

• 条件判断语法错误：[[ 和变量$a之间、]]与前面的表达式之间必须保留空格，bash会把[[$a识别为不存在的命令，直接触发语法报错。
• 退出码逻辑错误：else分支里用exit 0会让Airflow判定任务成功，但你需要标记任务失败，必须返回非0退出码（比如exit 1）。
• 冗余引号问题：条件里的"1"属于不必要的嵌套引号，可能引发解析异常。

修正后的脚本 #

a=0
if [[ $a -ge 1 ]]; then
    echo 'Job Success'
else
    echo 'Need Investigation'
    exit 1
fi

关键修改说明 #

• 给[[、]]前后添加空格，确保bash能正确识别条件判断语法。
• 将exit 0改为exit 1，非0退出码会触发Airflow的任务失败标记，匹配你的预期需求。
• 移除了脚本中多余的分号（bash中换行可替代分号作为命令分隔符，可读性更强）。

如果是在Airflow的BashOperator中使用，完整示例如下：

from airflow import DAG
from airflow.operators.bash import BashOperator
from datetime import datetime

with DAG(
    dag_id='conditional_task_dag',
    start_date=datetime(2024, 1, 1),
    schedule_interval=None
) as dag:
    conditional_task = BashOperator(
        task_id='conditional_check',
        bash_command="""
            a=0
            if [[ $a -ge 1 ]]; then
                echo 'Job Success'
            else
                echo 'Need Investigation'
                exit 1
            fi
        """
    )

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