POD“ NO2-PIPELINE-X5KPD-2954674781”无效:spec.volumes [3] .name:重复值:'no2-pvc;

发布于 2025-02-09 02:11:18 字数 2224 浏览 3 评论 0原文

嗨,我正在尝试运行KubeFlow管道。

两个步骤将并行运行,并将数据转储到PVC的两个不同文件夹中,然后第三个组件将将数据从这些文件收集到文件夹,并将它们合并在一起,并将合并的数据转移到另一个PVC文件夹中。

这是我的管道代码:

vop = dsl.VolumeOp(
            name='no2-pvc',
            resource_name = "no2-pvc",
            size="100Gi",
            modes = dsl.VOLUME_MODE_RWO
        )

    ##LOADING POSITIVE DATA##

    load_positive_data = dsl.ContainerOp(
        name='load_positive_data',
        image=load_positive_data_image,
        command="python",
        arguments=[
            "/app/load_positive_data.py",
        ],
        pvolumes={"/mnt/positive/": vop.volume}).apply(gcp.use_gcp_secret("user-gcp-sa"))


    ##LOADING NEGATIVE DATA##

    load_negative_data = dsl.ContainerOp(
        name='load_negative_data',
        image=load_negative_data_image,
        command="python",
        arguments=[
            "/app/load_negative_data.py",

        ],
        pvolumes={"/mnt/negative/": vop.volume}).apply(gcp.use_gcp_secret("user-gcp-sa"))

    
    ##MERGING POSITIVE AND NEGATIVE DATA##

    marge_pos_neg_data = dsl.ContainerOp(
        name='marge_pos_neg_data',
        image=marged_data_image,
        command="python",
        arguments=[
            "/app/merge_neg_pos.py"
        ],
        pvolumes = {"/mnt/positive/": load_negative_data.pvolume, "/mnt/negative/": load_positive_data.pvolume}
        #volumes={'/mnt': vop.after(load_negative_data, load_positive_data)}
    ).apply(gcp.use_gcp_secret("user-gcp-sa")).after(load_positive_data, load_negative_data)


    ##PROCESSING MARGED DATA##


    process_marged_data = dsl.ContainerOp(
        name='process_data',
        image=perpare_merged_data_image,
        command="python",
        arguments=[
            "/app/prepare_all_dataset.py"
        ], 
        pvolumes = {"/mnt/pos_neg": marge_pos_neg_data.pvolume}
    ).apply(gcp.use_gcp_secret("user-gcp-sa")).after(marge_pos_neg_data)

负载阳性数据和负载阴性数据运行良好,但是Marge-Pos-neg-Data步骤正在给出以下错误:

This step is in Error state with this message: 
task 'no2-pipeline-x5kpd.marge-pos-neg-data' 
errored: Pod "no2-pipeline-x5kpd-2954674781" is invalid: 
spec.volumes[3].name: Duplicate value: "no2-pvc"

希望您的帮助解决问题。

Hi I am trying to run a Kubeflow pipeline.

Two steps will run in parallel and dump data to two different folders of PVC, then the third component will collect data from those to folders and merge them together and dump the merged data to another PVC folder.

Here are my pipeline codes:

vop = dsl.VolumeOp(
            name='no2-pvc',
            resource_name = "no2-pvc",
            size="100Gi",
            modes = dsl.VOLUME_MODE_RWO
        )

    ##LOADING POSITIVE DATA##

    load_positive_data = dsl.ContainerOp(
        name='load_positive_data',
        image=load_positive_data_image,
        command="python",
        arguments=[
            "/app/load_positive_data.py",
        ],
        pvolumes={"/mnt/positive/": vop.volume}).apply(gcp.use_gcp_secret("user-gcp-sa"))


    ##LOADING NEGATIVE DATA##

    load_negative_data = dsl.ContainerOp(
        name='load_negative_data',
        image=load_negative_data_image,
        command="python",
        arguments=[
            "/app/load_negative_data.py",

        ],
        pvolumes={"/mnt/negative/": vop.volume}).apply(gcp.use_gcp_secret("user-gcp-sa"))

    
    ##MERGING POSITIVE AND NEGATIVE DATA##

    marge_pos_neg_data = dsl.ContainerOp(
        name='marge_pos_neg_data',
        image=marged_data_image,
        command="python",
        arguments=[
            "/app/merge_neg_pos.py"
        ],
        pvolumes = {"/mnt/positive/": load_negative_data.pvolume, "/mnt/negative/": load_positive_data.pvolume}
        #volumes={'/mnt': vop.after(load_negative_data, load_positive_data)}
    ).apply(gcp.use_gcp_secret("user-gcp-sa")).after(load_positive_data, load_negative_data)


    ##PROCESSING MARGED DATA##


    process_marged_data = dsl.ContainerOp(
        name='process_data',
        image=perpare_merged_data_image,
        command="python",
        arguments=[
            "/app/prepare_all_dataset.py"
        ], 
        pvolumes = {"/mnt/pos_neg": marge_pos_neg_data.pvolume}
    ).apply(gcp.use_gcp_secret("user-gcp-sa")).after(marge_pos_neg_data)

load-positive-data and load-negative-data are working fine but the marge-pos-neg-data step is giving the following error:

This step is in Error state with this message: 
task 'no2-pipeline-x5kpd.marge-pos-neg-data' 
errored: Pod "no2-pipeline-x5kpd-2954674781" is invalid: 
spec.volumes[3].name: Duplicate value: "no2-pvc"

Hoping for your help to resolve the issue.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

阳光下慵懒的猫 2025-02-16 02:11:18

pvolumes = {“/mnt/stustry/”:vop.volume})和pvolumes = {“/mnt/noad/noad/“:vop.volume})正在创建两个独立的PVC。

pvolumes={"/mnt/positive/": vop.volume}) and pvolumes={"/mnt/negative/": vop.volume}) was creating two separate pvc's.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文