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#
演员创建任务的函数描述符。
方法