我遇到了一个问题,那就是我的任务因为某种原因而没有被工人们接受。当我查看任务细节时:
满足所有依赖项,但任务实例没有运行。在大多数情况下,这只是意味着任务可能很快就会被调度,除非:-调度程序已经关闭或负载过重。 如果此任务实例没有很快启动,请与您的气流管理员联系以获得帮助。
我检查了调度程序,日志中没有错误,也重新启动了几次。
我还查看了气流网站日志,只注意到以下内容:
22/11/2018 12:10:392018-11-22 01:10:39,747 {cli.py:644}除错-5/5杀死1名工人22/11/2018 12:10:392018-11-22 01:10:39 +0000信息处理信号: ttou 22/11/2018 12:10:392018-11-22 01:10:39 +0000信息工作者退出(pid: 348)
不知道会发生什么,以前很好。
气流版本1.9.0,永远不要更改版本,只是围绕一些配置:min_file_process_interval和dag_dir_list_interval (但当遇到此问题时,我将其恢复到默认状态)

发布于 2018-11-22 03:37:27
我确实注意到,这发生在我玩一些气流配置和重建我们的对接气流图像,然后我恢复到原来的版本,这是过去的工作。然后问题解决了。
我还注意到,当我使用新建的图像时,在我的芹菜工人身上发生了一个错误(但并不总是捕捉到):
不可恢复的错误:AttributeError(“浮点”对象没有属性'items'“)
因此,如果发现它与最新发布的redis有关(芹菜将使用redis),您可以找到more details。
https://stackoverflow.com/questions/53422644
复制相似问题