将Dask延迟任务中的工作进度反馈给客户端线程



我想使用Daskdelayed任务来调用一个外部程序,该程序将其进度输出到STDOUT。在delayed中,我计划监视STDOUT,并希望用从STDOUT中提取的进度信息更新正在等待delayed任务的Client进程。有没有推荐的delayed任务与其Client进程通信的方法,或者我需要自己滚动?

您可以使用dask提供的任何协调原语或参与者来实现这种流。根据您的描述,Queue或pubsub机制似乎是最受欢迎的。您应该注意,所有这些通常都是低频和低音量通信的手段。

最新更新