ray.data.ActorPoolStrategy.__init__#

ActorPoolStrategy.__init__(legacy_min_size: Optional[int] = None, legacy_max_size: Optional[int] = None, *, size: Optional[int] = None, min_size: Optional[int] = None, max_size: Optional[int] = None, max_tasks_in_flight_per_actor: Optional[int] = None)[source]#

Construct ActorPoolStrategy for a Dataset transform.

Parameters

  • size – Specify a fixed size actor pool of this size. It is an error to specify both size and min_size or max_size.

  • min_size – The minimize size of the actor pool.

  • max_size – The maximum size of the actor pool.

  • max_tasks_in_flight_per_actor – The maximum number of tasks to concurrently send to a single actor worker. Increasing this will increase opportunities for pipelining task dependency prefetching with computation and avoiding actor startup delays, but will also increase queueing delay.