ray.rllib.evaluation.worker_set.WorkerSet.fetch_ready_async_reqs#

WorkerSet.fetch_ready_async_reqs(*, timeout_seconds: Optional[int] = 0, return_obj_refs: bool = False, mark_healthy: bool = False) → List[Tuple[int, ray.rllib.evaluation.worker_set.T]][source]#

Get esults from outstanding asynchronous requests that are ready.

Parameters

  • timeout_seconds – Time to wait for results. Default is 0, meaning those requests that are already ready.

  • mark_healthy – Whether to mark the worker as healthy based on call results.

Returns

A list of results successfully returned from outstanding remote calls, paired with the indices of the callee workers.