python - Apache Airflow：如何编写自定义传感器来检查特定条件并执行操作
问题描述
我想在 Airflow 2 中编写一个自定义传感器。标准过程是覆盖 poke 方法以检查您想要的条件并在达到时终止任务。但我想要的是让我的传感器最初执行操作，然后休眠并检查特定条件。
我如何通过覆盖 poke 方法来做到这一点。我要执行的操作必须只发生一次，但在每个戳间隔期间，戳方法都会运行以检查条件。我如何在不覆盖执行方法的情况下实现这一点？
解决方案
推荐阅读
- python - python，我想在for循环中使用函数
- python - 来自 2 列数据的图表
- python - 在python中使用逻辑回归的一对一和一对一多类分类
- javascript - 为什么这个代码打印错误的素数？
- jenkins - Jenkins groovy 脚本参数从另一个工作中获取
- python - 一次获取 Tensorflow 中多个元素的索引
- android - 如何重现错误？
- javascript - 如何在 Docker 上部署的 React JS 应用程序中隐藏 API 密钥和机密
- html - 为单选输入实现 CSS 默认浏览器
- c++ - ClipperLib 中 ptSubject 和 ptClip 的区别