Airflow 中的传感器- 是某种类型的操作符,会一直运行直到满足某个标准,但它们会占用一个完整的工作槽。好奇人们是否能够可靠地使用更有效的方法来实现这一点。
我的一些想法
其他相关链接:
如何在 Airflow 中实现轮询?
如何在使用 Airflow 实现的工作流中等待 DAG 任务中的异步事件?
python airflow airflow-scheduler
找不到任何现有的方法,所以我想知道是否有黑客攻击?
python argparse
python ×2
airflow ×1
airflow-scheduler ×1
argparse ×1