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”。
方法
开发者API: 此API可能会在Ray的次要版本之间发生变化。
用于使用选项执行actor方法调用的便捷方法。