ray#
Source code: tianshou/env/worker/ray.py
- class RayEnvWorker(env_fn: Callable[[], Env | PettingZooEnv])[source]#
Ray worker used in RayVectorEnv.
- recv() tuple[ndarray, ndarray, ndarray, ndarray, ndarray] [source]#
Receive result from low-level worker.
If the last “send” function sends a NULL action, it only returns a single observation; otherwise it returns a tuple of (obs, rew, done, info) or (obs, rew, terminated, truncated, info), based on whether the environment is using the old step API or the new one.
- send(action: ndarray | None, **kwargs: Any) None [source]#
Send action signal to low-level worker.
When action is None, it indicates sending “reset” signal; otherwise it indicates “step” signal. The paired return value from “recv” function is determined by such kind of different signal.
- static wait(workers: list[RayEnvWorker], wait_num: int, timeout: float | None = None) list[RayEnvWorker] [source]#
Given a list of workers, return those ready ones.