Airflow - 无效 JSON 配置,必须是字典

Airflow - Invalid JSON configuration, must be a dict

气流版本:2.1.1

我正在尝试使用配置触发 dag 并在下方传递 json

{"load_type":"full"}

但它会抛出一条错误消息“无效的 JSON 配置,必须是字典”

我也尝试用 3 个空格、2 个空格等格式化 json

{
   "load_type":"full"
}

但是没有用。在此版本之前,我使用的是 2.0.2,并且能够在触发 dag 时发送 json。

如有任何帮助,我们将不胜感激。谢谢

这是 2.1.1 中的一个错误,已被 PR 修复 升级到 Airflow 2.1.2 应该可以解决这个问题。

如果您无法升级,从 CLI 触发 DAG 应该在 2.1.1 中工作:

airflow dags trigger [-h] [-c CONF] [-e EXEC_DATE] [-r RUN_ID] [-S SUBDIR] dag_id