小编sha*_*rky的帖子

在 Airflow 中实现等待特定标准的有效方法

Airflow 中的传感器- 是某种类型的操作符,会一直运行直到满足某个标准,但它们会占用一个完整的工作槽。好奇人们是否能够可靠地使用更有效的方法来实现这一点。

我的一些想法

  • 使用池来限制分配给传感器的工作槽数量
  • 跳过下游的所有任务,然后通过外部触发器清除和恢复
  • 暂停 DAG 的运行并通过外部触发器再次恢复

其他相关链接:

python airflow airflow-scheduler

7
推荐指数
2
解决办法
3333
查看次数

如何从 ArgumentParser 实例中列出所有已注册的参数?

找不到任何现有的方法,所以我想知道是否有黑客攻击?

python argparse

3
推荐指数
1
解决办法
359
查看次数

标签 统计

python ×2

airflow ×1

airflow-scheduler ×1

argparse ×1