ray.actor.ActorMethod#

class ray.actor.ActorMethod(actor, method_name, num_returns: int | Literal['streaming'] | None, max_task_retries: int, retry_exceptions: bool | list | tuple, is_generator: bool, generator_backpressure_num_objects: int, enable_task_events: bool, decorator=None, hardref=False)[源代码]#

基类:object

用于调用actor方法的类。

注意:此类仅保持对actor的弱引用,除非它已被传递给远程函数。这避免了actor的GC延迟。

_actor_ref#

对演员的弱引用句柄。

_method_name#

演员方法的名称。

_num_returns#

方法调用应返回的默认返回值数量。如果给定 None,则对于普通 actor 任务使用 DEFAULT_ACTOR_METHOD_NUM_RETURN_VALS,对于生成器任务(当 is_generator 为 True 时)使用 “streaming”。

_max_task_retries#

方法失败时的重试次数。

_retry_exceptions#

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

_is_generator#

如果给定的方法是 Python 生成器,则为真。

_generator_backpressure_num_objects#

仅生成器配置。如果未消费对象的数量达到此阈值,则执行者任务将停止暂停。

enable_task_events#

如果启用了任务事件,则为 True,即应报告来自执行者的任务事件。默认为 True。

_decorator#

一个可选的装饰器,应在调用actor方法(而不是执行actor方法)之前应用于该调用。装饰器必须返回一个接受两个参数(“args”和“kwargs”)的函数。在大多数情况下,它应该调用传递给装饰器的函数并返回结果的ObjectRefs。有关示例,请参见“python/ray/tests/test_actor.py”中的“test_decorated_method”。

方法

bind

开发者API: 此API可能会在Ray的次要版本之间发生变化。

options

用于使用选项执行actor方法调用的便捷方法。