芹菜在dask或dramatiq中(bind = true)



我已经使用了一段时间了,但是由于缺乏窗户支持,正在寻找替代方案。

顶级竞争对手似乎是Dask和Dramatiq。我真正寻找的是可以将1000个长期运行任务分配到10台计算机上的东西。每个人都完成任务后,每个工作都应拿起下一个作业,并给出带有更新的回调(在芹菜中,这可以通过@task(bind = true)很好地实现,因为任务实例本身可以访问,我可以发送状态回到带有更新的实例)。

dramatiq或dask中是否有类似的功能?任何建议都将不胜感激。

在Dask侧您可能正在寻找期货接口:https://docs.dask.org/en/latest/futures.html

期货具有"完成"或"待处理"或"错误"之类的基本状态,您可以随时检查。如果您想要更复杂的消息,则应查看DASK队列,PubSub或其他插件通信机制,也可以从该文档页面提供。

相关内容

  • 没有找到相关文章

最新更新