Airflow安装中如何启动triggerer进程以正常使用TimeDeltaTrigger？

前置校验 #

请先确认你的Airflow版本大于等于2.2.0，可延迟运算符及Triggerer组件仅在2.2.0及以上版本支持。

按部署类型选择对应配置步骤 #

1. 原生命令行/systemd部署 #

• 打开airflow.cfg配置文件，确认[core]段下的deferrable_executors_pool_size值大于0，默认值为10可直接使用，也可按需调整
• 启动Triggerer进程，执行命令：airflow triggerer
• 若使用systemd管理Airflow服务，新增airflow-triggerer.service单元，配置逻辑与scheduler、worker服务一致，仅需将ExecStart字段改为上述启动命令，执行systemctl enable --now airflow-triggerer配置开机自启即可

2. Docker Compose部署 #

• 打开项目下的docker-compose.yml文件，新增Triggerer服务配置：

airflow-triggerer:
  image: apache/airflow:<你的实际Airflow版本号>
  command: triggerer
  user: "${AIRFLOW_UID:-50000}:0"
  environment:
    &airflow-common-env
    # 直接复用你现有配置中scheduler/worker服务的公共环境变量即可
  volumes:
    - ./dags:/opt/airflow/dags
    - ./logs:/opt/airflow/logs
    - ./plugins:/opt/airflow/plugins
  depends_on:
    &airflow-common-depends-on
    airflow-init:
      condition: service_completed_successfully

• 重启集群生效：docker compose up -d

3. Kubernetes Helm部署 #

• 若直接通过命令行升级发布，执行：helm upgrade --install airflow apache-airflow/airflow --set triggerer.enabled=true
• 若使用自定义values.yaml管理配置，修改对应配置段：

triggerer:
  enabled: true
  replicaCount: 1 # 生产环境可设置多副本保障高可用

• 重新应用Helm配置即可生效

配置验证 #

• 配置完成后进入Airflow Web UI，点击「Admin -> Workers」页面，可查看Triggerer进程的运行状态
• 重新触发包含TimeDeltaTrigger的DAG运行，进入「Browse -> Triggers」页面即可看到对应TimeDeltaTrigger实例，界面警告会自动消失

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