RunAPI

class deepfos.api.deep_pipeline.RunAPI(root: deepfos.api.base.RootAPI)

数据流的执行、获取执行信息等逻辑

result(task_id, timeout=None)

获取执行结果

参数

• task_id – str

• timeout – Optional[int]

返回类型

Union[Any, Awaitable[Any]]

run_async(run_info)

异步执行数据流 异步执行数据流，返回任务id

参数

run_info – Union[RunInfo, RunInfoWithParam]

返回类型

Union[str, Awaitable[str]]