我dask.distributed.Client用来连接到一个远程运行的 Dask 调度程序，该调度程序管理着一群工作人员。我正在使用client.submit并跟踪返回的内容提交我的工作Future：
client = Client("some-example-host:8786")
future = client.submit(job, job_args)
我希望能够知道作业是否/何时已发送到调度程序并被调度程序接受。这样我就可以在调度程序出现故障时添加一些重试逻辑。
是否有一种简单的方法可以确认调度程序已收到并接受该作业？
一些额外的点：
- 我意识到它
distributed.client.Future有一个status属性，但我犹豫要不要使用它，因为它没有记录在 API 中。 - 我试过使用
dask.callbacks.Callback但没有成功。任何有关使用回调的帮助distributed.Client将不胜感激。
编辑：我也可以让工作在开始时发回通知，但如果客户不支持，我想把这种方法作为最后的手段。