ray.util.dask.callbacks.RayDaskCallback._ray_预提交#

RayDaskCallback._ray_presubmit(task, key, deps) → Any | None[源代码]#

在提交 Ray 任务之前运行。

如果此回调返回一个非`None`的值，Ray 不会创建任务，而是将此值用作任务的结果值。

参数:

  • task – 一个 Dask 任务，其中元组的第一项是任务函数，其余元组项是任务参数，这些参数要么是实际的参数值，要么是 deps 字典中的 Dask 键，其对应的值是参数值。

  • key – 给定任务的 Dask 图键。

  • deps – 此任务的依赖项。

返回:

可以是 None，在这种情况下 Ray 提交一个任务，或者是一个非 None 值，在这种情况下 Ray 任务不提交任务并使用此返回值作为任务结果值。