Skip to content

chore: sync upstream kubeflow/pipelines [conflicts] - #369

Open
dsp-developers wants to merge 33 commits into
masterfrom
sync/upstream-merge-20260602-142936
Open

chore: sync upstream kubeflow/pipelines [conflicts]#369
dsp-developers wants to merge 33 commits into
masterfrom
sync/upstream-merge-20260602-142936

Conversation

@dsp-developers

Copy link
Copy Markdown

Automated sync from kubeflow/pipelines master branch.

Caution

This PR contains unresolved merge conflicts. The files listed below have
conflict markers (<<<<<<<, =======, >>>>>>>) that must be resolved
before merging.

Files with conflicts:

  • .github/workflows/api-server-tests.yml
  • .github/workflows/e2e-test.yml
  • .github/workflows/presubmit-backend.yml
  • .github/workflows/upgrade-test.yml
  • AGENTS.md
  • api/go.mod
  • backend/api/v2beta1/python_http_client/README.md
  • backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py
  • backend/src/apiserver/common/config.go
  • backend/src/apiserver/resource/resource_manager.go
  • backend/src/apiserver/resource/resource_manager_test.go
  • backend/src/apiserver/template/template_test.go
  • backend/src/apiserver/validation/pipeline_url.go
  • backend/src/apiserver/validation/pipeline_url_test.go
  • backend/src/v2/metadata/client.go
  • go.mod
  • kubernetes_platform/go.mod
  • test_data/compiled-workflows/pipeline_with_string_machine_fields_task_output.yaml

Excluded files (kept as downstream versions):

  • .tekton/*
  • .github/renovate.json5
  • backend/Dockerfile*
  • **/OWNERS

Overwritten paths (always taken from upstream):

  • frontend/

Created by the Upstream Sync workflow.

jeffspahr and others added 30 commits May 15, 2026 08:04
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: mprahl <11711106+mprahl@users.noreply.github.com>
…ubeflow#12750)

inital layout for pipeline url validation



revert dummy commit



fix de morgans law failure



minor updates



more refinements



adjust cidrs



fix tests



remove multicast



fix formatting



fix lint and tests



add gh user content to allow domains



fix typo



fix copilot concerns



fix jeff issues



implement jeff suggestions



more jeff feedback



revert most of last changes

Signed-off-by: JerT33 <trestjeremiah@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
…beflow#13325)

* fix(backend): apply recurring run service account unconditionally

The Argo compiler always sets a default ServiceAccountName on the
workflow spec, so executionSpec.ServiceAccount() is never empty for
V2 pipelines. This caused the user-specified service account from
the recurring run config to be silently dropped.

Remove the guard so setDefaultServiceAccount is called unconditionally,
matching the existing behavior in RunWorkflow.

Fixes kubeflow#13311

Signed-off-by: Feiyu Zhang <feiyuzhang@nianticlabs.com>

* test(backend): add test for recurring run with custom service account

Signed-off-by: Feiyu Zhang <feiyuzhang@nianticlabs.com>

---------

Signed-off-by: Feiyu Zhang <feiyuzhang@nianticlabs.com>
Co-authored-by: Feiyu Zhang <feiyuzhang@nianticlabs.com>
Signed-off-by: Helber Belmiro <helber.belmiro@gmail.com>
* added enable_debug_pause function

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* added in new changes

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed remaining failing test where the match string was not properly handled. It was due to incomplete setup. Also cleaned up code structure.

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* Improved design of Error checks in function, now the on_error=True and after=False happens first, since that was actually triggering the both False error first. This is better because it's more specific error, and it's often best practice to have more specific errors first.

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* Added new test that checks to make sure the enable_debug_pasue does not overwrite or effect other kubernetes helpers

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* cleaned up and removed leftover comment

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed spelling in debug.py file

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* cleaned up code: removed unused imports, added in correct spacing in RaiseValue errors, and corrected a docstring error/typo

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* Improved docstring by making sure that RaiseValue error matches the order of errors as shown/reflected in code

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* small text change to sign off

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed failing test that occured to changing message in RaiseValue

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* moved to SDK as method on PipelineTask

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed .gitignore

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* formatting fix

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* CICD fix failing test, testing quotes

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed pre_commit_hooks fix

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed docformatter error in pipeline

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fixed yapf error

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* fix pipeline_task docstring formatting for docformatter using earlier version of package

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* undid earlier version of formatting fix

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* used correct version of docformatter

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

* changed name from enable to set

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>

---------

Signed-off-by: Carlos Arroyo <arroyo.carlosdaniel@gmail.com>
Co-authored-by: Carlos Arroyo <carlosarroyo@Mac-13448.lan>
Co-authored-by: Carlos Arroyo <carlosarroyo@Mac-13683.lan>
Co-authored-by: Carlos Arroyo <carlosarroyo@Carloss-MacBook-Pro-2.local>
Signed-off-by: Helber Belmiro <helber.belmiro@gmail.com>
…flow#13434)

* fix: enforce V1 pipeline blocking with expanded test cases

Signed-off-by: cbartram <cbartram3@gmail.com>

* fix: improve V2 label handling and logging in scheduled workflow controller

Signed-off-by: cbartram <cbartram3@gmail.com>

* fix: update fakeExecutionInformer to return execution found status correctly

Signed-off-by: cbartram <cbartram3@gmail.com>

---------

Signed-off-by: cbartram <cbartram3@gmail.com>
…) (kubeflow#13437)

Mirror parameter OneOf resolution for artifact outputs by selecting the conditional branch that actually completed, improving the resulting error context, and by surfacing traversal errors during nested DAG collection. Add stronger regression tests, deterministic OneOf sample pipelines, and regenerated workflow goldens so compiler and E2E coverage consistently exercise the artifact OneOf runtime path.

Signed-off-by: mprahl <mprahl@users.noreply.github.com>
Fixes kubeflow#12845 (kubeflow#13009)

* feat(frontend,backend): show actual retry start time for pipeline runs

When a pipeline run is retried, the Start time shown in the UI previously
reflected the original scheduled time rather than the actual retry execution
time. This was misleading when debugging failures or SLA compliance issues.

Changes:
- backend: refactored RetryRun in resource_manager.go to update the full
  run object before persisting, preserving all existing fields correctly
- frontend: added getActualStartTime() in RunDetailsV2.tsx that reads the
  last RUNNING entry from state_history to determine the actual start time
- frontend: updated getDetailsFields() to show "Started at" as the actual
  execution time and conditionally insert "Scheduled at" when the two times
  differ

Fixes kubeflow#12845

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* fix(frontend): fall back to scheduled_at when RUNNING state update_time is undefined

getActualStartTime() returned undefined when a RUNNING state_history entry
existed but its update_time was not set, causing "Started at" to display "-"
even though a scheduled time was available.

Added a guard so that a missing update_time is treated the same as having no
RUNNING entries, and the fallback to scheduled_at is applied correctly.

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* style(frontend): fix prettier formatting in RunDetailsV2.tsx

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* test(frontend,backend): add tests for retry start time logic
- frontend: add tests for getActualStartTime() covering last RUNNING
  update_time, undefined update_time fallback, and equal-timestamp case
- frontend: fix timestamp comparison to use getTime() instead of
  formatDateString() to avoid locale/formatting false-equals
- frontend: insert 'Scheduled at' relative to 'Started at' using
  findIndex instead of a hard-coded index
- backend: add TestRetryRun_PreservesRunFields to verify UUID, name,
  experiment ID, FinishedAtInSec reset, and State after retry

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* fixed formatting error

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* fix(frontend): scan all RUNNING entries for most recent defined update_time

Previously getActualStartTime only checked the last RUNNING entry's
update_time, falling back to scheduled_at even if earlier RUNNING entries
had a valid time. This could hide the actual retry start time in
partially-populated state_history.

Now scans backwards through state_history to find the most recent RUNNING
entry with a defined update_time, only falling back to scheduled_at if
none are found.

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* fix(backend): remove redundant embedded field selector in test

golangci-lint QF1008: RunDetails is embedded in Run, so access
FinishedAtInSec and State directly without the RunDetails prefix.

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* fix(tests): address review feedback on retry tests

- frontend: add missing await before userEvent.click() in 3 new
  retry start time test cases to fix flaky CI failures
- backend: extend TestRetryRun_PreservesRunFields to assert
  StateHistory is preserved and appended with a new RUNNING entry
  after retry

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>

* Apply reviewer suggestion: use require.Nil/require.Greater for error
checks and precondition guards so the test fails fast instead of
continuing with nil values that would panic.

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>
Co-authored-by: Cursor <cursoragent@cursor.com>

---------

Signed-off-by: Sridhar1030 <sridharpillai75@gmail.com>
Co-authored-by: Cursor <cursoragent@cursor.com>
* fix(frontend): return to recurring runs on cancel

Signed-off-by: Jeff Spahr <spahrj@gmail.com>

* fix(frontend): honor return path in legacy new run

Signed-off-by: Jeff Spahr <spahrj@gmail.com>

---------

Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: JerT33 <trestjeremiah@gmail.com>

remove some verbose comments

Signed-off-by: JerT33 <trestjeremiah@gmail.com>

fix lint
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
Signed-off-by: Jeff Spahr <spahrj@gmail.com>
…beflow#13440)

* fix(backend): fix recurring runs with latest pipeline version

Signed-off-by: jaewak <jaewan.0907@gmail.com>

* fix: add missing ORDER BY to the query

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
Signed-off-by: jaewak <82007787+jaewak@users.noreply.github.com>

* build: fix precheck failures

Signed-off-by: jaewak <jaewan.0907@gmail.com>

* fix: make primary key uuid deterministic and resolve duplicate key conflict

Signed-off-by: jaewak <jaewan.0907@gmail.com>

* ci: re-trigger flaky E2E run

Signed-off-by: jaewak <jaewan.0907@gmail.com>

---------

Signed-off-by: jaewak <jaewan.0907@gmail.com>
Signed-off-by: jaewak <82007787+jaewak@users.noreply.github.com>
Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
kubeflow#13464)

Bump the Go builder image from golang:1.26.2-alpine to golang:1.26.3-alpine
(and golang:1.26.2-bookworm to golang:1.26.3-bookworm for the API server)
in the backend Dockerfiles not covered by kubeflow#13451, and update the toolchain
directive in all three go.mod files to match.

Addresses the same class of Go stdlib vulnerabilities tracked in kubeflow#13449.
kubeflow#13451 updated kfp-driver and kfp-launcher; this PR extends the same fix
to the remaining backend images built from the same toolchain:
- cache-server
- persistence-agent
- scheduled-workflow controller
- viewer-controller
- conformance test runner
- API server (bookworm variant)

Builder image digests pinned for reproducibility:
- golang:1.26.3-alpine  sha256:91eda9776261207ea25fd06b5b7fed8d397dd2c0a283e77f2ab6e91bfa71079d
- golang:1.26.3-bookworm sha256:386d475a660466863d9f8c766fec64d7fdad3edac2c6a05020c09534d71edb4b

Signed-off-by: Tolga Tuncoglu <tolgatuncoglu@gmail.com>
Signed-off-by: danish9039 <danishsiddiqui040@gmail.com>
juliusvonkohout and others added 3 commits June 1, 2026 19:12
* Update Argo Workflows resources to v3.7.14

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

* Update Argo workflow-controller reference to v3.7.14

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

* Update workflow-controller and executor images to v3.7.14

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

* Update Argo Workflows RBAC version in kustomization.yaml

Updated the Argo Workflows RBAC reference to version 3.7.14.

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

* Update kustomization.yaml

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

* Update workflow-controller-deployment-patch.yaml

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>

---------

Signed-off-by: Julius von Kohout <45896133+juliusvonkohout@users.noreply.github.com>
* feat(backend): Add plugin input/output fields to RecurringRun and Run protobufs (kubeflow#12919)

Signed-off-by: Helber Belmiro <helber.belmiro@gmail.com>

* feat(backend): Add pipeline run lifecycle hooks

Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>

* feat(backend) integrate MLflow lifecycle hooks across the driver and launcher (kubeflow#13052)

Signed-off-by: Alyssa Goins <80764587+alyssacgoins@users.noreply.github.com>

* chore(backend): Fix MLflow tags,nested run status update (kubeflow#13307)

Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>

* test(backend): Add MLFlow Integrations tests with KFP (kubeflow#13195)

Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>

* fix(backend): Address CI failures after rebase

Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>

* test(e2e): poll MLflow status after retry run failure (kubeflow#13468)

Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>

---------

Signed-off-by: Helber Belmiro <helber.belmiro@gmail.com>
Signed-off-by: Vani Haripriya Mudadla <vmudadla@redhat.com>
Signed-off-by: Alyssa Goins <80764587+alyssacgoins@users.noreply.github.com>
Co-authored-by: Helber Belmiro <helber.belmiro@gmail.com>
Co-authored-by: Alyssa Goins <80764587+alyssacgoins@users.noreply.github.com>
…ge-20260602-142936

# Conflicts:
#	.github/workflows/api-server-tests.yml
#	.github/workflows/e2e-test.yml
#	.github/workflows/presubmit-backend.yml
#	.github/workflows/upgrade-test.yml
#	AGENTS.md
#	api/go.mod
#	backend/Dockerfile
#	backend/Dockerfile.cacheserver
#	backend/Dockerfile.conformance
#	backend/Dockerfile.driver
#	backend/Dockerfile.launcher
#	backend/Dockerfile.persistenceagent
#	backend/Dockerfile.scheduledworkflow
#	backend/Dockerfile.viewercontroller
#	backend/api/v2beta1/python_http_client/README.md
#	backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py
#	backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py
#	backend/src/apiserver/common/config.go
#	backend/src/apiserver/resource/resource_manager.go
#	backend/src/apiserver/resource/resource_manager_test.go
#	backend/src/apiserver/template/template_test.go
#	backend/src/apiserver/validation/pipeline_url.go
#	backend/src/apiserver/validation/pipeline_url_test.go
#	backend/src/v2/metadata/client.go
#	go.mod
#	kubernetes_platform/go.mod
#	test_data/compiled-workflows/pipeline_with_string_machine_fields_task_output.yaml
@openshift-ci
openshift-ci Bot requested review from gmfrasca and hbelmiro June 2, 2026 14:29
@openshift-ci

openshift-ci Bot commented Jun 2, 2026

Copy link
Copy Markdown

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by:
Once this PR has been reviewed and has the lgtm label, please assign dsp-developers for approval. For more information see the Code Review Process.

The full list of commands accepted by this bot can be found here.

Details Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

@coderabbitai

coderabbitai Bot commented Jun 2, 2026

Copy link
Copy Markdown

Important

Review skipped

Too many files!

This PR contains 296 files, which is 146 over the limit of 150.

To get a review, narrow the scope:
• coderabbit review --type committed # exclude uncommitted changes
• coderabbit review --dir # limit to a subdirectory
• coderabbit review --base # compare against a closer base

⚙️ Run configuration

Configuration used: Central YAML (base), Organization UI (inherited)

Review profile: CHILL

Plan: Enterprise

Run ID: d20b7441-c47a-4a69-9fbf-c49a05a8b25b

📥 Commits

Reviewing files that changed from the base of the PR and between 54cf387 and 947074d.

⛔ Files ignored due to path filters (4)
  • api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go is excluded by !**/*.pb.go, !**/*.pb.go
  • backend/api/v2beta1/go_client/recurring_run.pb.go is excluded by !**/*.pb.go, !**/*.pb.go
  • backend/api/v2beta1/go_client/run.pb.go is excluded by !**/*.pb.go, !**/*.pb.go
  • go.sum is excluded by !**/*.sum, !**/*.sum
📒 Files selected for processing (296)
  • .github/actions/test-and-report/action.yml
  • .github/resources/scripts/configure-mlflow.sh
  • .github/workflows/api-server-tests.yml
  • .github/workflows/e2e-test-frontend.yml
  • .github/workflows/e2e-test.yml
  • .github/workflows/integration-tests-v1.yml
  • .github/workflows/kfp-kubernetes-native-migration-tests.yaml
  • .github/workflows/kfp-sdk-client-tests.yml
  • .github/workflows/kfp-webhooks.yml
  • .github/workflows/legacy-v2-api-integration-tests.yml
  • .github/workflows/presubmit-backend.yml
  • .github/workflows/upgrade-test.yml
  • AGENTS.md
  • api/go.mod
  • api/v2alpha1/pipeline_spec.proto
  • backend/api/v2beta1/go_http_client/recurring_run_model/v2beta1_recurring_run.go
  • backend/api/v2beta1/go_http_client/run_model/metadata_value_render_type.go
  • backend/api/v2beta1/go_http_client/run_model/v2beta1_metadata_value.go
  • backend/api/v2beta1/go_http_client/run_model/v2beta1_plugin_output.go
  • backend/api/v2beta1/go_http_client/run_model/v2beta1_plugin_state.go
  • backend/api/v2beta1/go_http_client/run_model/v2beta1_run.go
  • backend/api/v2beta1/python_http_client/README.md
  • backend/api/v2beta1/python_http_client/docs/MetadataValueRenderType.md
  • backend/api/v2beta1/python_http_client/docs/V2beta1MetadataValue.md
  • backend/api/v2beta1/python_http_client/docs/V2beta1PluginOutput.md
  • backend/api/v2beta1/python_http_client/docs/V2beta1PluginState.md
  • backend/api/v2beta1/python_http_client/docs/V2beta1RecurringRun.md
  • backend/api/v2beta1/python_http_client/docs/V2beta1Run.md
  • backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/metadata_value_render_type.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/v2beta1_metadata_value.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/v2beta1_plugin_output.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/v2beta1_plugin_state.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/v2beta1_recurring_run.py
  • backend/api/v2beta1/python_http_client/kfp_server_api/models/v2beta1_run.py
  • backend/api/v2beta1/python_http_client/test/test_metadata_value_render_type.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_list_recurring_runs_response.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_list_runs_response.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_metadata_value.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_plugin_state.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_recurring_run.py
  • backend/api/v2beta1/python_http_client/test/test_v2beta1_run.py
  • backend/api/v2beta1/recurring_run.proto
  • backend/api/v2beta1/run.proto
  • backend/api/v2beta1/swagger/kfp_api_single_file.swagger.json
  • backend/api/v2beta1/swagger/recurring_run.swagger.json
  • backend/api/v2beta1/swagger/run.swagger.json
  • backend/src/apiserver/client/kubernetes_core_fake.go
  • backend/src/apiserver/client/kubernetes_core_fake_test.go
  • backend/src/apiserver/client_manager/client_manager.go
  • backend/src/apiserver/client_manager/client_manager_test.go
  • backend/src/apiserver/common/config.go
  • backend/src/apiserver/common/config_test.go
  • backend/src/apiserver/common/const.go
  • backend/src/apiserver/config/config.json
  • backend/src/apiserver/main.go
  • backend/src/apiserver/model/common.go
  • backend/src/apiserver/model/job.go
  • backend/src/apiserver/model/run.go
  • backend/src/apiserver/plugins/dispatcher.go
  • backend/src/apiserver/plugins/handler.go
  • backend/src/apiserver/plugins/mlflow/config.go
  • backend/src/apiserver/plugins/mlflow/config_test.go
  • backend/src/apiserver/plugins/mlflow/dispatcher.go
  • backend/src/apiserver/plugins/mlflow/handler.go
  • backend/src/apiserver/plugins/mlflow/handler_test.go
  • backend/src/apiserver/plugins/mlflow/run_start.go
  • backend/src/apiserver/resource/resource_manager.go
  • backend/src/apiserver/resource/resource_manager_test.go
  • backend/src/apiserver/server/api_converter.go
  • backend/src/apiserver/server/api_converter_test.go
  • backend/src/apiserver/server/run_server.go
  • backend/src/apiserver/storage/db_fake.go
  • backend/src/apiserver/storage/job_store.go
  • backend/src/apiserver/storage/job_store_test.go
  • backend/src/apiserver/storage/run_store.go
  • backend/src/apiserver/storage/run_store_test.go
  • backend/src/apiserver/storage/sql_null_util.go
  • backend/src/apiserver/template/template_test.go
  • backend/src/apiserver/template/v2_template.go
  • backend/src/apiserver/validation/pipeline_url.go
  • backend/src/apiserver/validation/pipeline_url_test.go
  • backend/src/common/plugins/mlflow/client.go
  • backend/src/common/plugins/mlflow/client_test.go
  • backend/src/common/plugins/mlflow/config.go
  • backend/src/common/util/consts.go
  • backend/src/common/util/execution_spec.go
  • backend/src/common/util/uuid.go
  • backend/src/common/util/uuid_test.go
  • backend/src/common/util/workflow.go
  • backend/src/common/util/workflow_test.go
  • backend/src/crd/controller/scheduledworkflow/controller.go
  • backend/src/crd/controller/scheduledworkflow/controller_test.go
  • backend/src/crd/controller/scheduledworkflow/util/const.go
  • backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/types.go
  • backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/zz_generated.deepcopy.go
  • backend/src/v2/cmd/driver/main.go
  • backend/src/v2/cmd/launcher-v2/main.go
  • backend/src/v2/common/plugins/all/all.go
  • backend/src/v2/common/plugins/config.go
  • backend/src/v2/common/plugins/dispatcher.go
  • backend/src/v2/common/plugins/dispatcher_test.go
  • backend/src/v2/common/plugins/handler.go
  • backend/src/v2/common/plugins/mlflow/config.go
  • backend/src/v2/common/plugins/mlflow/config_test.go
  • backend/src/v2/common/plugins/mlflow/factory.go
  • backend/src/v2/common/plugins/mlflow/factory_test.go
  • backend/src/v2/common/plugins/mlflow/handler.go
  • backend/src/v2/common/plugins/mlflow/handler_test.go
  • backend/src/v2/common/plugins/registry.go
  • backend/src/v2/common/plugins/registry_test.go
  • backend/src/v2/compiler/argocompiler/common.go
  • backend/src/v2/compiler/argocompiler/container.go
  • backend/src/v2/compiler/argocompiler/dag.go
  • backend/src/v2/compiler/argocompiler/importer.go
  • backend/src/v2/component/launcher_v2.go
  • backend/src/v2/driver/container.go
  • backend/src/v2/driver/container_test.go
  • backend/src/v2/driver/dag.go
  • backend/src/v2/driver/driver.go
  • backend/src/v2/driver/driver_test.go
  • backend/src/v2/driver/k8s.go
  • backend/src/v2/driver/resolve.go
  • backend/src/v2/metadata/client.go
  • backend/src/v2/metadata/client_test.go
  • backend/test/config/flags.go
  • backend/test/constants/test_features.go
  • backend/test/end2end/mlflow_e2e_test.go
  • backend/test/end2end/utils/mlflow_utils.go
  • backend/test/proto_tests/testdata/generated-1791485/recurring_run.json
  • backend/test/proto_tests/testdata/generated-1791485/run_completed.json
  • backend/test/proto_tests/testdata/generated-1791485/run_completed_with_spec.json
  • backend/test/proto_tests/testdata/generated-1791485/run_failed.json
  • backend/test/v2/integration/run_api_test.go
  • frontend/src/apisv2beta1/recurringrun/models/V2beta1RecurringRun.ts
  • frontend/src/apisv2beta1/run/models/MetadataValueRenderType.ts
  • frontend/src/apisv2beta1/run/models/V2beta1MetadataValue.ts
  • frontend/src/apisv2beta1/run/models/V2beta1PluginOutput.ts
  • frontend/src/apisv2beta1/run/models/V2beta1PluginState.ts
  • frontend/src/apisv2beta1/run/models/V2beta1Run.ts
  • frontend/src/apisv2beta1/run/models/index.ts
  • frontend/src/components/Router.test.tsx
  • frontend/src/components/Router.tsx
  • frontend/src/lib/Buttons.ts
  • frontend/src/pages/AllRecurringRunsList.test.tsx
  • frontend/src/pages/NewRun.test.tsx
  • frontend/src/pages/NewRun.tsx
  • frontend/src/pages/NewRunV2.test.tsx
  • frontend/src/pages/NewRunV2.tsx
  • frontend/src/pages/RunDetailsV2.test.tsx
  • frontend/src/pages/RunDetailsV2.tsx
  • go.mod
  • kubernetes_platform/go.mod
  • manifests/gcp_marketplace/chart/kubeflow-pipelines/templates/pipeline.yaml
  • manifests/kustomize/base/installs/multi-user/api-service/cluster-role.yaml
  • manifests/kustomize/base/pipeline/ml-pipeline-apiserver-deployment.yaml
  • manifests/kustomize/base/pipeline/ml-pipeline-apiserver-role.yaml
  • manifests/kustomize/base/pipeline/pipeline-runner-role.yaml
  • manifests/kustomize/third-party/argo/base/kustomization.yaml
  • manifests/kustomize/third-party/argo/base/workflow-controller-deployment-patch.yaml
  • manifests/kustomize/third-party/argo/installs/cluster/kustomization.yaml
  • manifests/kustomize/third-party/argo/installs/namespace/cluster-scoped/kustomization.yaml
  • manifests/kustomize/third-party/argo/installs/namespace/kustomization.yaml
  • manifests/kustomize/third-party/seaweedfs/base/seaweedfs/seaweedfs-deployment.yaml
  • proposals/12147-mlmd-removal/test_plan.md
  • sdk/python/kfp/compiler/compiler_test.py
  • sdk/python/kfp/dsl/pipeline_task.py
  • sdk/python/kfp/dsl/pipeline_task_test.py
  • sdk/python/kfp/dsl/structures.py
  • sdk/python/kfp/dsl/structures_test.py
  • test_data/compiled-workflows/add_numbers.yaml
  • test_data/compiled-workflows/arguments_parameters.yaml
  • test_data/compiled-workflows/artifact_cache.yaml
  • test_data/compiled-workflows/artifact_crust.yaml
  • test_data/compiled-workflows/artifacts_complex.yaml
  • test_data/compiled-workflows/artifacts_simple.yaml
  • test_data/compiled-workflows/collected_artifacts.yaml
  • test_data/compiled-workflows/collected_parameters.yaml
  • test_data/compiled-workflows/component_with_env_variable.yaml
  • test_data/compiled-workflows/component_with_metadata_fields.yaml
  • test_data/compiled-workflows/component_with_optional_inputs.yaml
  • test_data/compiled-workflows/component_with_pip_index_urls.yaml
  • test_data/compiled-workflows/component_with_pip_install.yaml
  • test_data/compiled-workflows/component_with_pip_install_in_venv.yaml
  • test_data/compiled-workflows/components_with_optional_artifacts.yaml
  • test_data/compiled-workflows/concat_message.yaml
  • test_data/compiled-workflows/conditional_producer_and_consumers.yaml
  • test_data/compiled-workflows/container_component_with_no_inputs.yaml
  • test_data/compiled-workflows/container_io.yaml
  • test_data/compiled-workflows/container_no_input.yaml
  • test_data/compiled-workflows/container_with_artifact_output.yaml
  • test_data/compiled-workflows/container_with_concat_placeholder.yaml
  • test_data/compiled-workflows/container_with_if_placeholder.yaml
  • test_data/compiled-workflows/container_with_placeholder_in_fstring.yaml
  • test_data/compiled-workflows/containerized_python_component.yaml
  • test_data/compiled-workflows/create_pod_metadata_complex.yaml
  • test_data/compiled-workflows/cross_loop_after_topology.yaml
  • test_data/compiled-workflows/dict_input.yaml
  • test_data/compiled-workflows/embedded_artifact.yaml
  • test_data/compiled-workflows/env-var.yaml
  • test_data/compiled-workflows/fail_v2.yaml
  • test_data/compiled-workflows/flip_coin.yaml
  • test_data/compiled-workflows/hello_world.yaml
  • test_data/compiled-workflows/identity.yaml
  • test_data/compiled-workflows/if_elif_else_complex.yaml
  • test_data/compiled-workflows/if_elif_else_with_oneof_parameters.yaml
  • test_data/compiled-workflows/if_else_with_oneof_artifacts.yaml
  • test_data/compiled-workflows/if_else_with_oneof_parameters.yaml
  • test_data/compiled-workflows/input_artifact.yaml
  • test_data/compiled-workflows/iris_pipeline_compiled.yaml
  • test_data/compiled-workflows/lightweight_python_functions_pipeline.yaml
  • test_data/compiled-workflows/lightweight_python_functions_with_outputs.yaml
  • test_data/compiled-workflows/local_execution_pipeline_with_exit_handler.yaml
  • test_data/compiled-workflows/local_execution_pipeline_with_ignore_upstream_failure.yaml
  • test_data/compiled-workflows/local_execution_pipeline_with_k8s_only_methods.yaml
  • test_data/compiled-workflows/local_execution_pipeline_with_oneof.yaml
  • test_data/compiled-workflows/local_execution_pipeline_with_retry.yaml
  • test_data/compiled-workflows/log_streaming_compiled.yaml
  • test_data/compiled-workflows/long-running.yaml
  • test_data/compiled-workflows/loop_consume_upstream.yaml
  • test_data/compiled-workflows/metrics_visualization_v2.yaml
  • test_data/compiled-workflows/missing_kubernetes_optional_inputs.yaml
  • test_data/compiled-workflows/mixed_parameters.yaml
  • test_data/compiled-workflows/modelcar.yaml
  • test_data/compiled-workflows/mounted_cabundle_configmap.yaml
  • test_data/compiled-workflows/mounted_cabundle_secret.yaml
  • test_data/compiled-workflows/multiple_artifacts_namedtuple.yaml
  • test_data/compiled-workflows/multiple_parameters_namedtuple.yaml
  • test_data/compiled-workflows/nested_parallel_for_secret.yaml
  • test_data/compiled-workflows/nested_pipeline_opt_input_child_level_compiled.yaml
  • test_data/compiled-workflows/nested_pipeline_opt_inputs_nil_compiled.yaml
  • test_data/compiled-workflows/nested_pipeline_opt_inputs_parent_level_compiled.yaml
  • test_data/compiled-workflows/nested_return.yaml
  • test_data/compiled-workflows/nested_with_parameters.yaml
  • test_data/compiled-workflows/notebook_component_mixed.yaml
  • test_data/compiled-workflows/notebook_component_simple.yaml
  • test_data/compiled-workflows/output_metrics.yaml
  • test_data/compiled-workflows/parallel_for_after_dependency.yaml
  • test_data/compiled-workflows/parallel_for_mount_pvc.yaml
  • test_data/compiled-workflows/parallel_for_secret.yaml
  • test_data/compiled-workflows/parameter_cache.yaml
  • test_data/compiled-workflows/parameter_oneof.yaml
  • test_data/compiled-workflows/parameters_complex.yaml
  • test_data/compiled-workflows/parameters_simple.yaml
  • test_data/compiled-workflows/pipeline_as_exit_task.yaml
  • test_data/compiled-workflows/pipeline_in_pipeline.yaml
  • test_data/compiled-workflows/pipeline_in_pipeline_complex.yaml
  • test_data/compiled-workflows/pipeline_in_pipeline_loaded_from_yaml.yaml
  • test_data/compiled-workflows/pipeline_producer_consumer.yaml
  • test_data/compiled-workflows/pipeline_with_after.yaml
  • test_data/compiled-workflows/pipeline_with_artifact_custom_path.yaml
  • test_data/compiled-workflows/pipeline_with_artifact_upload_download.yaml
  • test_data/compiled-workflows/pipeline_with_caching.yaml
  • test_data/compiled-workflows/pipeline_with_collected_artifacts.yaml
  • test_data/compiled-workflows/pipeline_with_concat_placeholder.yaml
  • test_data/compiled-workflows/pipeline_with_condition.yaml
  • test_data/compiled-workflows/pipeline_with_condition_dynamic_task_output_custom_training_job.yaml
  • test_data/compiled-workflows/pipeline_with_dynamic_importer_metadata.yaml
  • test_data/compiled-workflows/pipeline_with_dynamic_task_output_custom_training_job.yaml
  • test_data/compiled-workflows/pipeline_with_env.yaml
  • test_data/compiled-workflows/pipeline_with_exit_handler.yaml
  • test_data/compiled-workflows/pipeline_with_google_artifact_type.yaml
  • test_data/compiled-workflows/pipeline_with_importer.yaml
  • test_data/compiled-workflows/pipeline_with_importer_and_gcpc_types.yaml
  • test_data/compiled-workflows/pipeline_with_importer_workspace.yaml
  • test_data/compiled-workflows/pipeline_with_input_status_state.yaml
  • test_data/compiled-workflows/pipeline_with_loops.yaml
  • test_data/compiled-workflows/pipeline_with_loops_and_conditions.yaml
  • test_data/compiled-workflows/pipeline_with_metadata_fields.yaml
  • test_data/compiled-workflows/pipeline_with_metrics_outputs.yaml
  • test_data/compiled-workflows/pipeline_with_multiple_exit_handlers.yaml
  • test_data/compiled-workflows/pipeline_with_nested_conditions.yaml
  • test_data/compiled-workflows/pipeline_with_nested_conditions_yaml.yaml
  • test_data/compiled-workflows/pipeline_with_nested_loops.yaml
  • test_data/compiled-workflows/pipeline_with_only_display_name.yaml
  • test_data/compiled-workflows/pipeline_with_outputs.yaml
  • test_data/compiled-workflows/pipeline_with_parallelfor_parallelism.yaml
  • test_data/compiled-workflows/pipeline_with_parallelfor_pipeline_param.yaml
  • test_data/compiled-workflows/pipeline_with_params_containing_format.yaml
  • test_data/compiled-workflows/pipeline_with_placeholders.yaml
  • test_data/compiled-workflows/pipeline_with_pod_metadata.yaml
  • test_data/compiled-workflows/pipeline_with_retry.yaml
  • test_data/compiled-workflows/pipeline_with_reused_component.yaml
  • test_data/compiled-workflows/pipeline_with_secret_as_env.yaml
  • test_data/compiled-workflows/pipeline_with_secret_as_volume.yaml
  • test_data/compiled-workflows/pipeline_with_string_machine_fields_pipeline_input.yaml
  • test_data/compiled-workflows/pipeline_with_string_machine_fields_task_output.yaml
  • test_data/compiled-workflows/pipeline_with_submit_request.yaml
  • test_data/compiled-workflows/pipeline_with_task_final_status.yaml
  • test_data/compiled-workflows/pipeline_with_task_final_status_yaml.yaml
  • test_data/compiled-workflows/pipeline_with_task_using_ignore_upstream_failure.yaml
  • test_data/compiled-workflows/pipeline_with_utils.yaml
  • test_data/compiled-workflows/pipeline_with_various_io_types.yaml
  • test_data/compiled-workflows/pipeline_with_volume.yaml
  • test_data/compiled-workflows/pipeline_with_volume_long_name.yaml

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

  • 🔍 Trigger review

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands and usage tips.

@dsp-developers

Copy link
Copy Markdown
Author

Commit Checker results:

**NOTE**: These are the results of the commit checker scans. 
If these are not commits from upstream kfp, then please ensure
you adhere to the commit checker formatting
commitchecker verson unknown
Validating 0 commits between 54cf3879d21b0206b59dd5ae4f4da58713793153...947074df199b6393e258a69dce1c7258cce26e0e

@openshift-ci

openshift-ci Bot commented Jun 10, 2026

Copy link
Copy Markdown

PR needs rebase.

Details

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.