airflow - 气流执行器
问题描述
我对使用气流还很陌生。我计划运行一些 dag,但它们按顺序运行。我希望它们开始彼此并行运行。因此,假设我有一个计划在下午 1 点运行的任务和另一个在下午 2 点运行的任务。如果第一个任务没有完成,到下午 2 点,我仍然希望下午 2 点任务开始运行并允许下午 1 点任务继续运行。
解决方案
如https://www.astronomer.io/guides/airflow-executors-explained/中所述,如果您想在任何时间点运行多个任务,则应使用LocalExecutor 。
推荐阅读
- python - 在我的 pygame 添加一个按钮后,以前没有给我带来任何问题的几件事现在给我带来了错误?
- apache-kafka - 当分区关闭时,Kafka 生产者是否将无密钥消息写入另一个分区?
- c - C提取中缀(char数组)并转换为int
- react-native - 遍历对象数组 react-native
- coq - Coq 中子列表的归纳命题
- opencv - 在 OpenCV 中转换 CV_16UC1 类型的深度图像
- java - 替换字符串java中的所有√num
- linux - 如何清理和管理overlay2 docker?
- javascript - 在 React 组件中的页面加载时自动上传文件不起作用
- python - 在 Python 中使用单例方法在日志包中创建一个实例