我正在考虑用dask替换芹菜 . 目前，我们有一个集群，其中提交了不同的作业，每个作业生成并行运行的多个任务 . Celery有一个杀手功能，即“撤销”命令：我可以杀死给定作业的所有任务，而不会干扰同时运行的其他作业 . 我怎么能用dask做到这一点？我只找到提及这是不可能的参考文献，但对我们来说这将是一场灾难 . 所以当计算变得流氓时，不要强迫关闭整个集群，从而杀死其他用户的工作 .
您可以使用 Client.cancel 命令取消任务 .
Client.cancel
如果他们还没有开始，那么他们将无法启动，但是如果他们已经在某个地方的某个线程中运行，那么除了拆除这个过程之外，没有太多的Python能够阻止它们 .
1 回答
您可以使用
Client.cancel命令取消任务 .如果他们还没有开始，那么他们将无法启动，但是如果他们已经在某个地方的某个线程中运行，那么除了拆除这个过程之外，没有太多的Python能够阻止它们 .