DeepPipelineAPI

class deepfos.api.deep_pipeline.DeepPipelineAPI(version: Optional[Union[float, str]] = None, header: Optional[dict] = None, sync: bool = <object object>, module_id: Optional[str] = None, lazy: bool = False)

DeepPipeline组件接口

flow: FlowAPI

数据流定义相关接口

open(element_name, folder_id, version)

查看数据流

run: RunAPI

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

run_async(run_info)	异步执行数据流 异步执行数据流，返回任务id
result(task_id[, timeout])	获取执行结果