问使用Kubeflow Pipeline kfp.ParallelFor时聚合结果
EN

Stack Overflow用户

提问于 2020-03-20 04:17:34

回答 2查看 268关注 0票数 4

什么是聚合Kubeflow Pipleine kfp.ParallelFor结果的好模式？

kubeflow

kubeflow-pipelines

回答 2

Stack Overflow用户

发布于 2020-05-05 20:24:33

目前，这可能不受支持：

Support inputs with multiple arguments #1933

票数 0

Stack Overflow用户

发布于 2021-07-30 07:04:12

这并不完全符合您的要求，但我们的变通方法是将并行任务的结果写入S3，然后在后处理任务中简单地收集它们。

with dsl.ParallelFor(preprocessing_task.output) as plant_item:
                predict_plant='{}'.format(plant_item)
                forecasting_task = forecasting_op(predict_plant, ....).after(preprocessing_task)
postprocessing_task = postprocessing_op(...).after(forecasting_task)

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/60764436

复制

相似问题

问使用Kubeflow Pipeline kfp.ParallelFor时聚合结果
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Kubeflow Pipeline kfp.ParallelFor时聚合结果EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Kubeflow Pipeline kfp.ParallelFor时聚合结果
EN