0

我正在尝试创建一个系统,通过该系统我首先列出一个 dag 的所有失败的任务实例,并允许用户选择他想要重新运行的那些。我使用如下调用获取失败任务实例的列表

curl --user 'test:tes' -X GET 'http://airflow-url:port/api/v1/dags/example_bash_operator/dagRuns/?/taskInstances?state=failed'

但这并没有为我提供实例的 run_id 我如何使用气流 API 获取任务实例的 run_id 我如何重新启动(清除)特定 dag 实例中的特定任务?API 允许清除我不打算的所有失败实例

4

0 回答 0