如何调用Flyte中已注册的LaunchPlan?求对应API方法
获取Flyte中已注册的LaunchPlan/Workflow的方法
Flyte提供了从已注册实体中获取LaunchPlan或Workflow的API,可实现你需要的类似LaunchPlan.fetch_latest的功能:
1. 获取已注册的LaunchPlan
使用LaunchPlan.fetch方法,省略version参数即可获取最新版本的LaunchPlan:
from flytekit import LaunchPlan # 获取指定项目、域下最新版本的LaunchPlan launch_plan = LaunchPlan.fetch( project="your-project", domain="your-domain", name="regression_line_workflow" )
2. 获取已注册的Workflow
若需直接获取Workflow,使用Workflow.fetch方法:
from flytekit import Workflow # 获取最新版本的Workflow workflow = Workflow.fetch( project="your-project", domain="your-domain", name="regression_line_workflow" ) # 可选:基于获取到的Workflow创建LaunchPlan launch_plan = LaunchPlan.get_or_create(workflow)
3. 适配你的场景的完整代码
from flytekit import LaunchPlan, workflow # 替换为你的项目和域名称 launch_plan = LaunchPlan.fetch( project="your-project", domain="your-domain", name="regression_line_workflow" ) @workflow def nested_regression_line_lp() -> float: # 触发已注册的LaunchPlan return launch_plan()
说明:project和domain是必填项,对应你Flyte部署中的项目与域配置;若需获取特定版本的实体,添加version参数(如version="v1")即可
内容的提问来源于stack exchange,提问作者Selva
相关产品推荐
相关产品推荐

