EnvRunnerGroup.foreach_worker_with_id(func: Callable[[int, EnvRunner], T], *, local_worker: bool = True, healthy_only: bool = False, remote_worker_ids: List[int] = None, timeout_seconds: float | None = None) List[T][source]#

Calls the given function with each EnvRunner and its ID as its arguments.

  • func – The function to call for each worker (as only arg).

  • local_worker – Whether apply func on local worker too. Default is True.

  • healthy_only – Apply func on known-to-be healthy workers only.

  • remote_worker_ids – Apply func on a selected set of remote workers.

  • timeout_seconds – Time to wait for results. Default is None.


The list of return values of all calls to func([worker, id]).

DeveloperAPI: This API may change across minor Ray releases.