yr.object_ref.ObjectRef

yr.object_ref.ObjectRef#

class yr.object_ref.ObjectRef(object_id: str, task_id=None, need_incre=True, need_decre=True, exception=None)#

基类:object

对象引用,即数据对象的键。

属性

id

ObjectRef的id。

task_id

任务ID。

方法

__init__

as_future

使用 asyncio.Future 包装 ObjectRef。

cancel

取消对象的未来任务。

done

如果对象的未来任务已被取消或执行完成,则返回 True。

exception

如果异常不为 None,则抛出异常。

get

此函数用于 FaaS 模式中检索对象。

get_future

获取未来任务。

is_exception

是否为未来任务异常。

on_complete

注册回调函数。

set_data

设置数据。

set_exception

设置异常。

wait

等待任务完成。