Argo: проблема в данный момент для генерации вывода из модуля

Question

У меня есть конвейер argo, в котором я извлекаю некоторые данные и создаю файл с данными. Но я попытался сохранить файл и создать вывод, но всегда получаю эту ошибку:

не удалось сохранить выходные данные: истекло время ожидания условия

Поэтому я сгенерировал тест только с эхом и получил тот же результат.

код:

      import kfp
from kfp import dsl
from kfp.components import func_to_container_op, InputPath, OutputPath
from kubernetes.client.models import (
    V1Volume,
    V1SecretVolumeSource,
    V1PersistentVolumeClaimVolumeSource,
    V1SecretReference,
    V1EnvFromSource,
    V1EnvVar,
    V1SecretReference,
    V1EnvFromSource
)


opt_volume = V1Volume(
    name="clickup",
    persistent_volume_claim=V1PersistentVolumeClaimVolumeSource(
        claim_name="argo-artifacts"
    )
)


def extract_teams():
    return kfp.dsl.ContainerOp(
        name="extract-teams",
        image="java:8-jdk",
        command=["bash", "-c"],
        arguments=[
            "echo 2290945 > /tmp/teams.txt"
        ],
        pvolumes={"/opt/": opt_volume},
        container_kwargs={
            "env_from": [
                V1EnvFromSource(
                    secret_ref=V1SecretReference(name="clickup-secrets")
                )
            ],
        },
        file_outputs={"out": "/tmp/teams.txt"},
    )



def print_list_dir():
    return kfp.dsl.ContainerOp(
        name="list-dir",
        image="python:3",
        command=["bash", "-c"],
        arguments=[
            f""" python -c 'import os;  lst = os.listdir(\"/opt/clickup/\") ; print(lst) ' """
        ],
        pvolumes={"/opt/": opt_volume},
    )


@func_to_container_op
def print_data(message: str):
    import logging
    logging.basicConfig(level=logging.INFO)
    print(message)


@dsl.pipeline(
    name='Click Up Extractor Pipeline',
    description='Click Up Extractions'
)
def hello_world_pipeline():
    bulk_teams = extract_teams()
    print_data(bulk_teams.output)


if __name__ == '__main__':
    kfp.compiler.Compiler().compile(hello_world_pipeline, __file__ + '.yaml')

изображение:

что случилось?