We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KFP version: Vertex Pipelines
KFP SDK version: 1.8.2
Run the following pipeline on Vertex Pipelines:
from kfp import components from kfp import dsl import kfp.v2.compiler as compiler @components.create_component_from_func def print_op(msg: str): print(msg) @dsl.pipeline( name='pipeline-with-loops-and-conditions', pipeline_root=PIPELINE_ROOT, ) def my_pipeline(text_parameter: str = '[{"p_a": -1, "p_b": ["hello", "world"]}, {"p_a": 2, "p_b": ["nihao", "shijie"]}]'): with dsl.ParallelFor(text_parameter) as item: with dsl.Condition(item.p_a != "-1"): with dsl.ParallelFor(item.p_b) as item_p_b: print_op(item_p_b) compiler.Compiler().compile(pipeline_func=my_pipeline, package_path='loops-and-conditions.json')
Expect no error
Get HTTP 400 error with message: Component input parameter 'pipelineparam--text_parameter-loop-item' is not defined
Component input parameter 'pipelineparam--text_parameter-loop-item' is not defined
The text was updated successfully, but these errors were encountered:
fix(sdk.v2): Fix a couple of ParallelFor related bugs. Fixes #6383, f…
b466f59
…ixes #6628 (#6643) * fix a couple of loop related bugs * add release note
chensun
Successfully merging a pull request may close this issue.
Environment
KFP version:
Vertex Pipelines
KFP SDK version:
1.8.2
Steps to reproduce
Run the following pipeline on Vertex Pipelines:
Expected result
Expect no error
Actual results
Get HTTP 400 error with message:
Component input parameter 'pipelineparam--text_parameter-loop-item' is not defined
The text was updated successfully, but these errors were encountered: