ray.actor.ActorHandle#

class ray.actor.ActorHandle(language, actor_id, max_task_retries: int | None, enable_task_events: bool, method_is_generator: Dict[str, bool], method_decorators, method_signatures, method_num_returns: Dict[str, int | Literal['streaming']], method_max_task_retries: Dict[str, int], method_retry_exceptions: Dict[str, bool | list | tuple], method_generator_backpressure_num_objects: Dict[str, int], method_enable_task_events: Dict[str, bool], actor_method_cpus: int, actor_creation_function_descriptor, cluster_and_job, original_handle=False, weak_ref: bool = False)[源代码]#

基类:object

一个指向演员的句柄。

此类中的字段以 _ray_ 为前缀,以对用户隐藏它们,并避免与actor方法名称发生冲突。

ActorHandle 可以通过三种方式创建。首先,通过在 ActorClass 上调用 .remote()。其次,通过将 actor handle 传递给任务(分叉 ActorHandle)。第三,通过直接序列化 ActorHandle(例如,使用 cloudpickle)。

_ray_actor_language#

演员语言。

_ray_actor_id#

演员 ID。

_ray_enable_task_events#

任务事件是否启用的默认值,即应报告来自执行者的任务事件。

_ray_method_is_generator#

方法名称映射 -> 是否为生成器方法。

_ray_method_decorators#

函数调用的可选装饰器。这可以用来改变调用端的行为,而常规的装饰器可以用来改变执行端的行为。

_ray_method_signatures#

演员方法的签名。

_ray_method_max_task_retries#

方法失败时的最大重试次数。

_ray_method_num_returns#

每个方法的默认返回值数量。

_ray_method_retry_exceptions#

是否要重试所有用户引发的异常的布尔默认值,或要重试的允许异常列表。

_ray_method_generator_backpressure_num_objects#

仅生成器配置。在生成器开始暂停之前要生成的最大对象数。

_ray_method_enable_task_events#

是否为actor方法启用任务跟踪的值。这将覆盖actor的默认值(_ray_enable_task_events)。

_ray_actor_method_cpus#

执行者方法所需的CPU数量。

_ray_original_handle#

如果这是给定角色的原始角色句柄,则为真。如果这是真的,那么当这个句柄超出作用域时,角色将被销毁。

_ray_weak_ref#

True 表示此句柄不计入演员的分布式引用计数,即当此句柄仍在作用域内时,演员可能会被垃圾回收。如果句柄是通过按名称获取演员或通过获取自身句柄创建的,则此项设置为 True。如果这是原始句柄,或者如果它是通过将原始句柄传递给任务参数和返回值创建的,则此项设置为 False。

_ray_is_cross_language#

这个演员是否跨语言。

_ray_actor_creation_function_descriptor#

演员创建任务的函数描述符。

方法