ray.rllib.env.env_runner_group.EnvRunnerGroup.获取已准备好的异步请求#

EnvRunnerGroup.fetch_ready_async_reqs(*, timeout_seconds: float | None = 0.0, return_obj_refs: bool = False, mark_healthy: bool = True) → List[Tuple[int, T]][源代码]#

获取已经准备好的优秀异步请求的结果。

参数:

  • timeout_seconds – 等待结果的时间。默认值为0，表示那些已经准备好的请求。

  • return_obj_refs – 是否返回 ObjectRef 而不是实际结果。

  • mark_healthy – 是否将所有当前标记为不健康的且在给定的 timeout_seconds 内从远程调用返回结果的工人再次标记为健康。请注意，如果工人只是超时（仅当他们返回 RayActorError 时），他们不会被设置为不健康。另请注意，如果 healthy_only=True`（因为 `mark_healthy 仅影响当前标记为不健康的工人），则此设置将被忽略。

返回:

从远程调用中成功返回的结果列表，与调用者工作者的索引配对。

开发者API: 此API可能会在Ray的次要版本之间发生变化。