ap1*_*234 5 airflow
我可以在外部(使用http请求吗?)将与dag_id和run_id关联的特定task_id标记为成功/失败。
我的任务是外部系统上长时间运行的任务,我不希望我的任务轮询系统以查找状态..因为我们可能可以同时运行几个 1000 个任务..
理想情况下希望我的任务
谢谢
kvb*_*kvb 1
Airflow 还没有 Rest 端点。但是,您有几个选择 - 使用气流命令行实用程序将作业标记为成功。例如,在 python 中使用 Popen。- 直接更新Airflow DB表task_instance
归档时间:
9 年,2 月 前
查看次数:
5686 次
最近记录:
6 年,6 月 前