AI Slop Code RIsk Monitor

kubeflow/pipelines

Machine Learning Pipelines for Kubeflow

11.1 Moderate pattern signal View on GitHub

Maintenance and Governance Review

This report summarizes scanner evidence for kubeflow/pipelines, a Go project with 4,238 GitHub stars. SynthScan examined 911,793 lines of code across 3680 source files, recording 7165 pattern matches distributed across 22 syntactic categories. The legacy adjusted pattern signal is 11.1 (Moderate pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

11.1
Adjusted Signal
11.1
Raw Pattern Score
100%
Time Factor
2026-10-11
Last Push
4.2K
Stars
Go
Language
911.8K
Lines of Code
3.7K
Files
7.2K
Pattern Hits
2026-10-12
Scan Date
0.19
HC Hit Rate

Risk Review · v3

Use each vector to guide manual verification of the underlying findings.

Cognitive Ownership Risk 26.6/100 · MEDIUM

Can maintainers explain intent, assumptions, and trade-offs? 5550 finding(s).

Hallucinated Dependency & Supply Chain Risk 7.9/100 · LOW

Are imports declared and package/API names verified? 850 finding(s).

Agent Over-Engineering Ratio 26.6/100 · MEDIUM

Are wrappers, guards, and repeated structures necessary? 3798 finding(s).

PR Review Velocity Impact 45.6/100 · MEDIUM

Which changes need focused human review? 7165 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 1HIGH 716MEDIUM 183LOW 6265

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 7165 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hyper-Verbose Identifiers2871 hits · 2545 pts
SeverityFileLineSnippetContext
LOWfrontend/server/k8s-helper.ts59function getConfiguredServerNamespace(): string | undefined {CODE
LOWfrontend/server/k8s-helper.ts226export async function deleteTensorboardInstance(logdir: string, namespace: string): Promise<void> {CODE
LOWfrontend/server/k8s-helper.ts248export function waitForTensorboardInstance(CODE
LOWfrontend/server/app.ts41function hardenPodLogsProxyResponse(proxyRes: IncomingMessage): void {CODE
LOWfrontend/server/minio-helper.ts71export function getArtifactStoreOriginAfterRewrite(CODE
LOWfrontend/server/minio-helper.ts77export function parseArtifactStoreEndpoint(CODE
LOWfrontend/server/minio-helper.ts283export async function createArtifactStoreClient(CODE
LOWfrontend/server/minio-helper.ts341async function createMinioClientWithProviderInfo(CODE
LOWfrontend/server/minio-helper.ts445function createConfiguredMinioClient(config: MinioClientOptionsWithOptionalSecrets): MinioClient {CODE
LOWfrontend/server/minio-helper.ts945function containsInvalidSecondLayerEscape(rawPath: string): boolean {CODE
LOWfrontend/server/minio-helper.ts1200function extractFirstTarRecordAsStream() {CODE
LOWfrontend/server/minio-helper.ts1424export async function summarizeDirectoryUnderPrefix(CODE
LOWfrontend/server/utils.ts292function normalizeRelativeVolumePath(CODE
LOWfrontend/server/utils.ts316function isVolumePathInsideSubPath(filePathInVolume: string, volumeMountSubPath: string): boolean {CODE
LOWfrontend/server/workflow-helper.ts131export function createPodLogsStreamFromWorkflow(trustedEndpoints: string[]) {CODE
LOWfrontend/server/workflow-helper.ts183export async function getKeyFormatFromArtifactRepositories(CODE
LOWfrontend/server/workflow-helper.ts232export function createPodLogsMinioRequestConfig(CODE
LOWfrontend/server/workflow-helper.ts303export async function getPodLogsMinioRequestConfigfromWorkflow(CODE
LOWfrontend/server/initialize-tensorboard-signing-key.ts27export async function initializeTensorboardSigningKey(CODE
LOWfrontend/server/configs.ts47function validateConfiguredEndpointPort(CODE
LOWfrontend/server/configs.ts74function parseAllowedArtifactEndpoints(value: string): string[] {CODE
LOWfrontend/server/configs.ts104function getArgoArtifactRepositoryEndpoints(CODE
LOWfrontend/server/configs.ts132function resolveTensorboardProxySigningSecret(CODE
LOW…ontend/server/integration-tests/artifact-proxy.test.ts62 async function setUpNamespacedArtifactService({CODE
LOWfrontend/server/integration-tests/tensorboard.test.ts105 function newGetTensorboardResponse({CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts46function signTensorboardProxyPayload(serializedPayload: string, signingSecret: string): string {CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts58function isDocumentNavigationRequest(req: Pick<express.Request, 'method' | 'headers'>): boolean {CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts93export function createTensorboardProxyPath(CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts110export function buildTensorboardProxyTarget(CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts121export function buildTensorboardProxyUpstreamPath(CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts136export function getTensorboardProxyBasePath(proxyPrefix: string, referer = ''): string | undefined {CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts156function isSafeTensorboardProxyPath(proxyPath: string): boolean {CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts174export function parseTensorboardProxyPayload(CODE
LOWfrontend/server/handlers/tensorboard-proxy.ts231export function parseTensorboardProxyRequest(CODE
LOWfrontend/server/handlers/artifacts.ts153function hardenArtifactProxyResponse(proxyResponse: IncomingMessage): void {CODE
LOWfrontend/server/handlers/artifacts.ts248function retainDestinationSafeProviderInfo(providerInfoString: string): string {CODE
LOWfrontend/server/handlers/artifacts.ts345export function getArtifactsAuthMiddleware(CODE
LOWfrontend/server/handlers/artifacts.ts1056function validateArtifactQueryParameters(CODE
LOWfrontend/server/handlers/artifacts.ts1076function hasAsciiControlCharacters(value: string): boolean {CODE
LOWfrontend/server/handlers/artifacts.ts1286function isHttpArtifactRedirectInNamespace(CODE
LOWfrontend/server/handlers/artifacts.ts1308function parseAllowedHttpArtifactUrl(url: string, allowedDomain: string): string | undefined {CODE
LOWfrontend/server/handlers/artifacts.ts1379function isArtifactRequestCancelled(req: Request, res: Response, error: unknown): boolean {CODE
LOWfrontend/server/handlers/artifacts.ts1599function buildAttachmentDisposition(filename: string): string {CODE
LOWfrontend/server/handlers/artifacts.ts1614function hardenUpstreamContentDisposition(value: string | string[] | undefined): string {CODE
LOWfrontend/server/handlers/artifacts.ts1839function getVolumeArtifactsHandler(options: { bucket: string; key: string }, peek: number = 0) {CODE
LOWfrontend/server/handlers/artifacts.ts2125function removeVolumeCurrentDirectorySegments(key: string): string {CODE
LOWfrontend/server/handlers/domain-checker.ts29export function isTrustedArtifactEndpoint(CODE
LOWfrontend/server/helpers/artifact-validator.ts25export function normalizeArtifactOwnershipMode(value?: string): ArtifactOwnershipMode {CODE
LOWfrontend/server/helpers/artifact-validator.ts41export function resolveArtifactValidationTimeoutMs(CODE
LOWfrontend/server/helpers/artifact-validator.ts88export function validateArtifactKeyPrefix(CODE
LOWfrontend/server/helpers/artifact-validator.ts146export async function validateArtifactNamespace(CODE
LOW⚡frontend/server/helpers/launcher-config.ts309function pruneExpiredLauncherConfigurationCacheEntries(now: number): void {CODE
LOW⚡frontend/server/helpers/launcher-config.ts317function evictLauncherConfigurationCacheOverflow(): void {CODE
LOW⚡frontend/server/helpers/launcher-config.ts327async function loadLauncherConfiguration(namespace: string): Promise<LauncherConfiguration> {CODE
LOWfrontend/server/helpers/launcher-config.ts463function validateOptionalProviderField(CODE
LOWfrontend/server/helpers/launcher-config.ts491function formatLauncherStringScalar(value: number | bigint | boolean): string {CODE
LOWfrontend/server/helpers/launcher-config.ts638function throwInvalidProviderShape(path: string, expected: string): never {CODE
LOWfrontend/server/helpers/launcher-config.ts783function validateNativeBooleanOption(params: Record<string, string>, option: string): void {CODE
LOWfrontend/server/helpers/artifact-sources.ts42export function requiresArtifactOwnershipValidation(source: string): boolean {CODE
LOWfrontend/server/helpers/artifact-sources.ts46export function artifactProviderForSource(source: LauncherArtifactSource): ArtifactProvider {CODE
2811 more matches not shown…
Cross-File Repetition460 hits · 2300 pts
SeverityFileLineSnippetContext
HIGH…-backend/data/v2/pipeline/xgboost_sample_pipeline.yaml0converts csv table to apache parquet.\n\n [apache parquet](https://parquet.apache.org/)\n\ \n annotations:\n author: aleSTRING
HIGHfrontend/src/data/test/xgboost_sample_pipeline.yaml0converts csv table to apache parquet.\n\n [apache parquet](https://parquet.apache.org/)\n\ \n annotations:\n author: aleSTRING
HIGH…_compiled_pipelines/valid/xgboost_sample_pipeline.yaml0converts csv table to apache parquet.\n\n [apache parquet](https://parquet.apache.org/)\n\ \n annotations:\n author: aleSTRING
HIGH…src/apiserver/server/test/xgboost_sample_pipeline.yaml0converts csv table to apache parquet.\n\n [apache parquet](https://parquet.apache.org/)\n\ \n annotations:\n author: aleSTRING
HIGH…-backend/data/v2/pipeline/xgboost_sample_pipeline.yaml0make predictions using a trained xgboost model.\n\n args:\n \ \ data_path: path for the feature data in csv format.\n moSTRING
HIGHfrontend/src/data/test/xgboost_sample_pipeline.yaml0make predictions using a trained xgboost model.\n\n args:\n \ \ data_path: path for the feature data in csv format.\n moSTRING
HIGH…_compiled_pipelines/valid/xgboost_sample_pipeline.yaml0make predictions using a trained xgboost model.\n\n args:\n \ \ data_path: path for the feature data in csv format.\n moSTRING
HIGH…src/apiserver/server/test/xgboost_sample_pipeline.yaml0make predictions using a trained xgboost model.\n\n args:\n \ \ data_path: path for the feature data in csv format.\n moSTRING
HIGH…-backend/data/v2/pipeline/xgboost_sample_pipeline.yaml0make predictions\ \ using a trained xgboost model.\n\n args:\n data_path: path for\ \ the feature data in apache parquetSTRING
HIGHfrontend/src/data/test/xgboost_sample_pipeline.yaml0make predictions\ \ using a trained xgboost model.\n\n args:\n data_path: path for\ \ the feature data in apache parquetSTRING
HIGH…_compiled_pipelines/valid/xgboost_sample_pipeline.yaml0make predictions\ \ using a trained xgboost model.\n\n args:\n data_path: path for\ \ the feature data in apache parquetSTRING
HIGH…src/apiserver/server/test/xgboost_sample_pipeline.yaml0make predictions\ \ using a trained xgboost model.\n\n args:\n data_path: path for\ \ the feature data in apache parquetSTRING
HIGH…-backend/data/v2/pipeline/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n\ \ training_data_path: path for the training data in csv format.\n\ \ model_path: ouSTRING
HIGHfrontend/src/data/test/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n\ \ training_data_path: path for the training data in csv format.\n\ \ model_path: ouSTRING
HIGH…_compiled_pipelines/valid/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n\ \ training_data_path: path for the training data in csv format.\n\ \ model_path: ouSTRING
HIGH…src/apiserver/server/test/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n\ \ training_data_path: path for the training data in csv format.\n\ \ model_path: ouSTRING
HIGH…-backend/data/v2/pipeline/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n training_data_path:\ \ path for the training data in apache parquet format.\n model_STRING
HIGHfrontend/src/data/test/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n training_data_path:\ \ path for the training data in apache parquet format.\n model_STRING
HIGH…_compiled_pipelines/valid/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n training_data_path:\ \ path for the training data in apache parquet format.\n model_STRING
HIGH…src/apiserver/server/test/xgboost_sample_pipeline.yaml0train an xgboost model.\n\n args:\n training_data_path:\ \ path for the training data in apache parquet format.\n model_STRING
HIGH…/sdk_compiled_pipelines/valid/pipeline_as_exit_task.py0pipeline using exithandler with pipelinetaskfinalstatus.STRING
HIGH…led_pipelines/valid/pipeline_with_task_final_status.py0pipeline using exithandler with pipelinetaskfinalstatus.STRING
HIGH…lid/critical/pipeline_with_artifact_upload_download.py0pipeline using exithandler with pipelinetaskfinalstatus.STRING
HIGH…st_data/sdk_compiled_pipelines/valid/output_metrics.py0dummy component that outputs metrics with a random accuracy.STRING
HIGH…lines/valid/essential/pipeline_with_metrics_outputs.py0dummy component that outputs metrics with a random accuracy.STRING
HIGHsdk/python/kfp/compiler/compiler_test.py0dummy component that outputs metrics with a random accuracy.STRING
HIGH…luation/evaluation_automl_unstructure_data_pipeline.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…model_evaluation/evaluation_automl_tabular_pipeline.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…luation_automl_tabular_feature_attribution_pipeline.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…_evaluation/evaluation_feature_attribution_pipeline.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…ure_attribution/feature_attribution_graph_component.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…odel_evaluation/feature_attribution_graph_component.py0a pipeline to compute feature attributions by sampling data for batch explanations. this pipeline guarantees support forSTRING
HIGH…omponents/v1/dataset/create_image_dataset/component.py0creates a new video [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) andSTRING
HIGH…components/v1/dataset/create_text_dataset/component.py0creates a new video [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) andSTRING
HIGH…omponents/v1/dataset/create_video_dataset/component.py0creates a new video [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) andSTRING
HIGH…components/v1/dataset/export_text_dataset/component.py0exports [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) to a gcs outputSTRING
HIGH…ponents/v1/dataset/export_tabular_dataset/component.py0exports [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) to a gcs outputSTRING
HIGH…omponents/v1/dataset/export_video_dataset/component.py0exports [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) to a gcs outputSTRING
HIGH…omponents/v1/dataset/export_image_dataset/component.py0exports [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) to a gcs outputSTRING
HIGH…nts/v1/dataset/export_time_series_dataset/component.py0exports [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.datasets) to a gcs outputSTRING
HIGH…omponents/v1/dataset/import_video_dataset/component.py0uploads data to an existing managed [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locatioSTRING
HIGH…omponents/v1/dataset/import_image_dataset/component.py0uploads data to an existing managed [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locatioSTRING
HIGH…components/v1/dataset/import_text_dataset/component.py0uploads data to an existing managed [dataset](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locatioSTRING
HIGH…e_components/v1/bigquery/ml_training_info/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…ipeline_components/v1/bigquery/drop_model/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…eline_components/v1/bigquery/create_model/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…ipeline_components/v1/bigquery/ml_weights/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…ne_components/v1/bigquery/ml_feature_info/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…omponents/v1/bigquery/ml_advanced_weights/component.py0launch a bigquery ml advanced weights job and waits for it to finish. args: location: location of the job to create the STRING
HIGH…nents/v1/bigquery/ml_principal_components/component.py0launch a bigquery ml trial info job and waits for it to finish. args: location: location to run the bigquery ml trial inSTRING
HIGH…components/v1/bigquery/feature_importance/component.py0launch a bigquery ml trial info job and waits for it to finish. args: location: location to run the bigquery ml trial inSTRING
HIGH…s/v1/bigquery/ml_principal_component_info/component.py0launch a bigquery ml trial info job and waits for it to finish. args: location: location to run the bigquery ml trial inSTRING
HIGH…line_components/v1/bigquery/ml_trial_info/component.py0launch a bigquery ml trial info job and waits for it to finish. args: location: location to run the bigquery ml trial inSTRING
HIGH…mponents/v1/dataproc/create_pyspark_batch/component.py0create a dataproc spark batch workload and wait for it to finish. args: location: location of the dataproc batch workloaSTRING
HIGH…mponents/v1/dataproc/create_spark_r_batch/component.py0create a dataproc spark batch workload and wait for it to finish. args: location: location of the dataproc batch workloaSTRING
HIGH…components/v1/dataproc/create_spark_batch/component.py0create a dataproc spark batch workload and wait for it to finish. args: location: location of the dataproc batch workloaSTRING
HIGH…ipeline_components/container/v1/custom_job/launcher.py0gcp launcher for custom jobs based on the ai platform sdk.STRING
HIGH…ne_components/container/v1/custom_job/remote_runner.py0gcp launcher for custom jobs based on the ai platform sdk.STRING
HIGH…ne_components/container/preview/custom_job/launcher.py0gcp launcher for custom jobs based on the ai platform sdk.STRING
HIGH…mponents/container/preview/custom_job/remote_runner.py0gcp launcher for custom jobs based on the ai platform sdk.STRING
400 more matches not shown…
Over-Commented Block2015 hits · 2001 pts
SeverityFileLineSnippetContext
LOWrequirements.txt1# This file was autogenerated by uv via the following command:COMMENT
LOWrequirements.txt21 # via clickCOMMENT
LOWrequirements.txt41 # via kfpCOMMENT
LOWrequirements.txt61 # viaCOMMENT
LOWrequirements.txt81 # kubernetesCOMMENT
LOWrequirements.txt101tabulate==0.9.0COMMENT
LOWtools/diagnose/kfp.sh1#!/bin/bashCOMMENT
LOWtools/k8s-native/migration.py1# Copyright 2025 The Kubeflow AuthorsCOMMENT
LOWfrontend/tsconfig.prod.json1{COMMENT
LOWfrontend/server/app.test.ts1// Copyright 2019-2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/aws-helper.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOW…tend/server/initialize-tensorboard-signing-key.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/utils.test.ts1// Copyright 2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/k8s-helper.ts1// Copyright 2018 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/aws-helper.test.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/minio-helper.integration.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/gcs-helper.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/app.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/minio-helper.ts1// Copyright 2019-2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/k8s-helper.test.ts1// Copyright 2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/utils.ts1// Copyright 2018-2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/utils.ts481 }COMMENT
LOWfrontend/server/configs.test.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/minio-helper.test.ts1// Copyright 2019-2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/workflow-helper.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/workflow-helper.ts361 }COMMENT
LOWfrontend/server/initialize-tensorboard-signing-key.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/configs.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/gcs-helper.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/server.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/workflow-helper.test.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOW…end/server/integration-tests/pod-logs-endpoint.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…er/integration-tests/profile-artifact-endpoint.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…ntend/server/integration-tests/mock-api-server.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/integration-tests/artifact-get.test.ts1// Copyright 2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/integration-tests/artifact-auth.test.ts1// Copyright 2025 The Kubeflow AuthorsCOMMENT
LOW…ntegration-tests/mock-backend-query-validation.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…ver/integration-tests/artifact-proxy-ownership.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…d/server/integration-tests/mock-backend-routes.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…ver/integration-tests/multi-user-artifact-rbac.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/integration-tests/tensorboard.test.ts1// Copyright 2021 The Kubeflow AuthorsCOMMENT
LOW…egration-tests/testdata/profile-artifact-repository.py1# Copyright 2026 The Kubeflow AuthorsCOMMENT
LOW…gration-tests/testdata/profile-artifact-environment.py1# Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/tensorboard-proxy.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/pod-logs.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/tensorboard.ts1// Copyright 2019-2021 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/artifacts.ts1// Copyright 2019-2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/healthz.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/artifacts.test.ts1// Copyright 2025 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/domain-checker.ts1// Copyright 2023 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/pod-info.ts1// Copyright 2020 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/domain-checker.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/index-html.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/tensorboard-proxy.test.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/pod-logs.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/handlers/gke-metadata.ts1// Copyright 2019 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/helpers/provider-options.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/helpers/artifact-validator.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/helpers/artifact-path.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
LOWfrontend/server/helpers/launcher-config.ts1// Copyright 2026 The Kubeflow AuthorsCOMMENT
1955 more matches not shown…
Cross-Language Confusion96 hits · 618 pts
SeverityFileLineSnippetContext
HIGH⚡sdk/python/test/presubmit_output_test.py72 'test "$3" = kfp && test "$4" = --wheel && 'STRING
HIGH⚡sdk/python/test/presubmit_output_test.py73 'test "$5" = --out-dir || exit 2\n'STRING
HIGH⚡sdk/python/test/presubmit_output_test.py77 'test "$1" = run && test "$2" = python || exit 2\n'STRING
HIGH⚡sdk/python/test/presubmit_output_test.py77 'test "$1" = run && test "$2" = python || exit 2\n'STRING
HIGHsdk/python/kfp/cli/component.py370 response = client.images.push(STRING
HIGHsdk/python/kfp/dsl/component_factory.py134 python3 -m ensurepip || python3 -m ensurepip --user || apt-get install python3-pipCODE
HIGH⚡sdk/python/kfp/dsl/component_factory_test.py50 '\nif ! [ -x "$(command -v pip)" ]; then\n python3 -m ensurepip || python3 -m ensurepip --user || aptCODE
HIGHsdk/python/kfp/dsl/component_factory_test.py74 '\nif ! [ -x "$(command -v pip)" ]; then\n python3 -m ensurepip || python3 -m ensurepip --user || aptCODE
HIGHsdk/python/kfp/dsl/component_factory_test.py121 '\nif ! [ -x "$(command -v pip)" ]; then\n python3 -m ensurepip || python3 -m ensurepip --user || aptCODE
HIGHsdk/python/kfp/dsl/component_factory_test.py158 ' python3 -m ensurepip || python3 -m ensurepip --user || apt-get install 'CODE
HIGHsdk/python/kfp/dsl/component_factory_test.py182 ' python3 -m ensurepip || python3 -m ensurepip --user || apt-get install 'CODE
HIGHsdk/python/kfp/dsl/component_factory_test.py211 ' python3 -m ensurepip || python3 -m ensurepip --user || apt-get install 'CODE
HIGHsdk/python/kfp/dsl/component_factory_test.py239 ' python3 -m ensurepip || python3 -m ensurepip --user || apt-get install 'CODE
HIGH⚡.github/resources/scripts/artifact_upload_retry_test.py43 'steps.primary.outputs.artifact-url || steps.retry.outputs.artifact-url',CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py44 result.requests.push({kind: 'getPR', request});CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py53 result.requests.push({kind: 'approve', request});CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py57 result.approved.push(request.run_id);CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py63 result.requests.push({kind: 'listPRs', request});CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py67 result.requests.push({kind: 'listRuns', request});CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py80 error: message => result.errors.push(message),CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py81 notice: message => result.notices.push(message),CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py82 warning: message => result.warnings.push(message),CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py83 setFailed: message => result.failures.push(message),CODE
HIGH⚡.github/resources/scripts/approval_fast_path_test.py91 process.stderr.write(error.stack || String(error));CODE
HIGH⚡…sources/scripts/artifact_workflow_test_support_test.py39 self.assertFalse(evaluate('!true == false && false', {}))CODE
HIGH⚡…sources/scripts/artifact_workflow_test_support_test.py40 self.assertTrue(evaluate('true || false && false', {}))CODE
HIGH⚡…sources/scripts/artifact_workflow_test_support_test.py40 self.assertTrue(evaluate('true || false && false', {}))CODE
HIGH⚡…sources/scripts/artifact_workflow_test_support_test.py41 self.assertFalse(evaluate('(true || false) && false', {}))CODE
HIGH⚡…sources/scripts/artifact_workflow_test_support_test.py48 render('${{ true }}/${{ false }}/${{ null }}', {}), 'true/false/')CODE
HIGH.github/resources/scripts/ci_base_workflows_test.py103 graphql: async (query, variables) => {requests.push({query, variables}); return fixture.response;},CODE
HIGH.github/resources/scripts/ci_base_workflows_test.py337 'if': '${{ false || true }}'STRING
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py60if (options.initialStatus) statusHistory.push({context: 'ci-passed',CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py61 created_at: options.registrationStartedAt || new Date().toISOString()});CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py63 calls.push(['base-workflows', variables]);CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py86 const status = published && options.drift === 'external-rerun' ? 'in_progress' :CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py89 published && options.drift === 'external-failure' ? 'failure' :CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py90 options.pollPassed === false && !(options.recoverLast && cycle === options.cycles - 1) ? 'failure' : 'success';CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py93 started_at: '2026-09-07T11:00:00Z', completed_at: status === 'completed' ? '2026-09-07T12:00:00Z' : null,CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py97 addLabels: async request => {calls.push(['add-label', request.labels]);},CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py99 calls.push(['remove-label', request.name]);CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py105 statusHistory.push({context: 'ci-passed', created_at: options.registrationStartedAt || new Date().toISOString()});CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py105 statusHistory.push({context: 'ci-passed', created_at: options.registrationStartedAt || new Date().toISOString()});CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py108 descriptions.push(description);CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py109 targetUrls.push(request.target_url);CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py110 calls.push(['status', request.state, request.sha]);CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py150 const recoveryBefore = options.verifyRecovery ? await gate.recoveryCandidates({github, context}) : null;CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py151 for (cycle = 0; cycle < (options.cycles || 1); cycle++) {CODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py160 pollPassed: outputs.ready === 'true' && !options.checkerFailure && (options.pollPassed !== false || (options.recovCODE
HIGH⚡.github/resources/scripts/ci_pass_eligibility_test.py163 const recoveryAfter = options.verifyRecovery ? await gate.recoveryCandidates({github, context}) : null;CODE
HIGH.github/resources/scripts/ci_pass_eligibility_test.py74 if (options.upgradePolicy) definitions.push({name: 'upgrade-test.yml', content:CODE
HIGH.github/resources/scripts/ci_pass_eligibility_test.py135 const conclusion = published && options.drift === 'rerun' ? 'cancelled' : (options.conclusions?.[cycle] || options.cCODE
HIGH.github/resources/scripts/ci_pass_eligibility_test.py138 status: options.runStatus || 'completed', conclusion: options.runStatus && options.runStatus !== 'completed' ? nulCODE
HIGH.github/resources/scripts/ci_pass_eligibility_test.py277 requests.push(ref);CODE
HIGH.github/resources/scripts/approval_recovery_test.py47if (options.needsLabel) pr.labels.push({name: 'needs-ok-to-test'});CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py62 calls.push(['get-pr']);CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py71 calls.push(['approve', request.run_id]);CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py80 calls.push(['list-prs', params.head || 'all']);CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py81 if (params.head && options.lateAmbiguity) return [pr, duplicate];CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py82 if (params.head && options.lateReplacement) return [duplicate];CODE
HIGH⚡.github/resources/scripts/approval_recovery_test.py86 calls.push(['list-runs', params.event, params.status, params.head_sha]);CODE
36 more matches not shown…
Unused Imports624 hits · 538 pts
SeverityFileLineSnippetContext
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py22CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py26CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py27CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py29CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py32CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py32CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py33CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py33CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py42CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py47CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py47CODE
LOW…-native-migration-tests/kfp_db_mode_migration_tests.py47CODE
LOW…rnetes-native-migration-tests/create_test_pipelines.py16CODE
LOW…rnetes-native-migration-tests/create_test_pipelines.py17CODE
LOW…rnetes-native-migration-tests/create_test_pipelines.py18CODE
LOW…rnetes-native-migration-tests/create_test_pipelines.py23CODE
LOW…iled_pipelines/valid/pipeline_with_secret_as_volume.py27CODE
LOW…ompiled_pipelines/valid/pipeline_container_no_input.py14CODE
LOW…k_compiled_pipelines/valid/metrics_visualization_v2.py34CODE
LOW…el_and_nested/pipeline_in_pipeline_loaded_from_yaml.py15CODE
LOW…nes/valid/parallel_and_nested/loop_consume_upstream.py4CODE
LOW…_and_nested/nested_pipeline_opt_inputs_parent_level.py1CODE
LOW…_compiled_pipelines/valid/critical/mixed_parameters.py3CODE
LOW…dk_compiled_pipelines/valid/critical/artifact_crust.py3CODE
LOW…ines/valid/essential/pipeline_with_reused_component.py15CODE
LOW…2beta1/python_http_client_smoke/test_package_import.py10CODE
LOW…2beta1/python_http_client_smoke/test_package_import.py27CODE
LOW…2beta1/python_http_client_smoke/test_package_import.py28CODE
LOW…2beta1/python_http_client_smoke/test_package_import.py30CODE
LOW…2beta1/python_http_client_smoke/test_package_import.py32CODE
LOW…2beta1/python_http_client_smoke/test_task_endpoints.py24CODE
LOWsamples/core/loop_output/loop_output_test.py15CODE
LOWsamples/core/exit_handler/exit_handler.py17CODE
LOWsamples/core/loop_static/loop_static_test.py15CODE
LOWsamples/core/condition/condition_test.py15CODE
LOWsamples/core/loop_parameter/loop_parameter_test.py15CODE
LOWsamples/core/tfx-oss/utils/taxi_utils.py23CODE
LOWsamples/core/tfx-oss/utils/taxi_utils.py24CODE
LOW…gle-cloud/google_cloud_pipeline_components/__init__.py18CODE
LOW…ogle_cloud_pipeline_components/v1/dataflow/__init__.py18CODE
LOW…ogle_cloud_pipeline_components/v1/dataflow/__init__.py19CODE
LOW…le_cloud_pipeline_components/v1/custom_job/__init__.py18CODE
LOW…le_cloud_pipeline_components/v1/custom_job/__init__.py19CODE
LOW…le_cloud_pipeline_components/v1/custom_job/__init__.py20CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py16CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py17CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py18CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py19CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py20CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py21CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py22CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py23CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py24CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py25CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py26CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py27CODE
LOW…odel_evaluation/model_based_llm_evaluation/__init__.py16CODE
LOW…ne_components/v1/vertex_notification_email/__init__.py16CODE
LOW…oogle_cloud_pipeline_components/v1/dataset/__init__.py18CODE
LOW…oogle_cloud_pipeline_components/v1/dataset/__init__.py19CODE
564 more matches not shown…
Docstring Block Structure83 hits · 415 pts
SeverityFileLineSnippetContext
HIGHrelease/kfpr/core.py54Derive release metadata from release type and version. Args: release_type: One of 'major', 'minor', oSTRING
HIGHrelease/kfpr/core.py128Load state from JSON file. Args: path: Path to state file. Returns: ReleaseState iSTRING
HIGHrelease/kfpr/core.py479Parse GitHub owner from fork remote URL. Args: fork_remote: Git remote URL (SSH or HTTPS format). Returns: STRING
HIGH…line_components/v1/dataflow/flex_template/component.py62Launch a job with a Dataflow Flex Template. Args: location: The regional endpoint to which to direct the request.STRING
HIGH…_evaluation/evaluation_llm_text_generation_pipeline.py56LLM Text Generation Evaluation pipeline. This pipeline supports evaluating large language models, publisher or manageSTRING
HIGH…l_evaluation/evaluation_llm_classification_pipeline.py65The LLM Text Classification Evaluation pipeline. Args: project: Required. The GCP project that runs the pipeline STRING
HIGH…luation_automl_tabular_feature_attribution_pipeline.py67The evaluation AutoML tabular pipeline with feature attribution for classification models. This pipeline guarantees sSTRING
HIGH…luation_automl_tabular_feature_attribution_pipeline.py244The evaluation AutoML tabular pipeline with feature attribution for regression models. This pipeline guarantees suppoSTRING
HIGH…_evaluation/evaluation_feature_attribution_pipeline.py69The evaluation custom tabular pipeline with feature attribution for classification models. This pipeline gives supporSTRING
HIGH…_evaluation/evaluation_feature_attribution_pipeline.py278The evaluation custom tabular pipeline with feature attribution for. regression models. This pipeline gives supporSTRING
HIGH…model_based_llm_evaluation/autosxs/autosxs_pipeline.py60Evaluates two models side-by-side using an arbiter model. Args: evaluation_dataset: A BigQuery table or comma-sepSTRING
HIGH…ine_components/v1/bigquery/evaluate_model/component.py45Launch a BigQuery evaluate model job and waits for it to finish. Args: location: Location to run the BigQuery mSTRING
HIGH…ponents/v1/bigquery/ml_arima_coefficients/component.py42Launch a BigQuery ML.ARIMA_COEFFICIENTS job and let you see the ARIMA coefficients. This function only applies to tSTRING
HIGH…e_components/v1/bigquery/ml_training_info/component.py41Launch a BigQuery ml training info fetching job and waits for it to finish. Args: location: Location of the jSTRING
HIGH…ipeline_components/v1/bigquery/drop_model/component.py38Launch a BigQuery drop model job and waits for it to finish. Args: location: Location of the job to drop the BiSTRING
HIGH…nents/v1/bigquery/ml_principal_components/component.py42Launch a BigQuery ML.principal_components job and waits for it to finish. Args: location: Location to run the BSTRING
HIGH…eline_components/v1/bigquery/create_model/component.py39Launch a BigQuery create model job and waits for it to finish. Args: location: Location of the job to create thSTRING
HIGH…eline_components/v1/bigquery/ml_centroids/component.py43Launch a BigQuery ML.CENTROIDS job and waits for it to finish. Args: location: Location to run the BigQuery ML.STRING
HIGH…ipeline_components/v1/bigquery/ml_weights/component.py41Launch a BigQuery ml weights job and waits for it to finish. Args: location: Location of the job to create the STRING
HIGH…line_components/v1/bigquery/predict_model/component.py45Launch a BigQuery predict model job and waits for it to finish. Args: location: Location to run the BigQuery moSTRING
HIGH…ne_components/v1/bigquery/ml_feature_info/component.py41Launch a BigQuery feature info job and waits for it to finish. Args: location: Location of the job to run BigQuSTRING
HIGH…ponents/v1/bigquery/explain_predict_model/component.py46Launch a BigQuery explain predict model job and waits for it to finish. Args: location: Location to run the BigSTRING
HIGH…components/v1/bigquery/feature_importance/component.py42Launch a BigQuery feature importance fetching job and waits for it to finish. Args: location: Location of theSTRING
HIGH…s/v1/bigquery/ml_principal_component_info/component.py42Launch a BigQuery ML.principal_component_info job and waits for it to finish. Args: location: Location to runSTRING
HIGH…omponents/v1/bigquery/ml_confusion_matrix/component.py44Launch a BigQuery confusion matrix job and waits for it to finish. Args: location: Location to run the BigQuerySTRING
HIGH…ine_components/v1/bigquery/forecast_model/component.py44Launch a BigQuery ML.FORECAST job and let you forecast an ARIMA_PLUS or ARIMA model. This function only applies to STRING
HIGH…omponents/v1/bigquery/ml_advanced_weights/component.py41Launch a BigQuery ml advanced weights job and waits for it to finish. Args: location: Location of the job to crSTRING
HIGH…_components/v1/bigquery/ml_arima_evaluate/component.py43Launch a BigQuery ML.ARIMA_EVALUATE job and waits for it to finish. Args: location: Location to run the BigQuerSTRING
HIGH…line_components/v1/bigquery/ml_trial_info/component.py42Launch a BigQuery ml trial info job and waits for it to finish. Args: location: Location to run the BigQuery mlSTRING
HIGH…onents/v1/bigquery/explain_forecast_model/component.py44Launch a BigQuery ML.EXPLAIN_FORECAST job and let you explain forecast an ARIMA_PLUS or ARIMA model. This function STRING
HIGH…onents/v1/bigquery/ml_reconstruction_loss/component.py43Launch a BigQuery ml reconstruction loss job and waits for it to finish. Args: location: Location to run the BiSTRING
HIGH…eline_components/v1/bigquery/ml_roc_curve/component.py44Launch a BigQuery roc curve job and waits for it to finish. Args: location: Location of the job to run BigQuerySTRING
HIGH…eline_components/v1/bigquery/ml_recommend/component.py44Launch a BigQuery ML.Recommend job and waits for it to finish. Args: location: Location to run the BigQuery ML.STRING
HIGH…onents/v1/bigquery/detect_anomalies_model/component.py46Launch a BigQuery detect anomalies model job and waits for it to finish. Args: location: Location to run the BiSTRING
HIGH…pipeline_components/v1/bigquery/query_job/component.py40Launch a BigQuery query job and waits for it to finish. Note: The total input commands/args to the component can be aSTRING
HIGH…e_components/v1/hyperparameter_tuning_job/component.py45Creates a Vertex AI hyperparameter tuning job and waits for it to complete. See [more information](https://cloud.goSTRING
HIGH…eline_components/v1/endpoint/deploy_model/component.py48[Deploys](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.endpoints/deployModel) a Google CSTRING
HIGH…pipeline_components/v1/model/upload_model/component.py48[Uploads](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.locations.models/upload) a Google Cloud VerSTRING
HIGH…_pipeline_components/v1/batch_predict_job/component.py69Creates a Google Cloud Vertex [BatchPredictionJob](https://cloud.google.com/vertex-ai/docs/reference/rest/v1/projects.loSTRING
HIGH…ainer/v1/dataflow/dataflow_python_job_remote_runner.py64Creates a Dataflow python job. Args: python_module_path: The gcs path to the python file to run. project: ReqSTRING
HIGH…ainer/v1/dataflow/dataflow_python_job_remote_runner.py165Parse a gcs path into bucket name and blob name. Args: path: the path to parse. Returns: A Tuple consistinSTRING
HIGH…ts/container/v1/gcp_launcher/pipeline_remote_runner.py184Poll the pipeline status with automatic retry. Args: get_pipeline_fn: A function that polls the pipeline fromSTRING
HIGH…omponents/container/v1/dataproc/utils/dataproc_util.py92GET a http request. Args: url: The resource url. Returns: Dict of the JSON payload returned in theSTRING
HIGH…omponents/container/v1/dataproc/utils/dataproc_util.py133POST a http request. Args: url: The resource url. post_data: The POST data. Returns: Dict ofSTRING
HIGH…omponents/container/v1/dataproc/utils/dataproc_util.py247Waits for a Dataproc batch workload to reach a final state. Args: lro: Dict of the long-running Operation resSTRING
HIGH…tainer/preview/dataflow/flex_template/remote_runner.py104POST a http request. Args: url: The resource url. post_data: The POST data. Returns: Dict ofSTRING
HIGH…tainer/preview/dataflow/flex_template/remote_runner.py200Create a job using a Dataflow Flex Template. Args: type: Job type that is written to gcp_resources. jobSTRING
HIGH…ents/_implementation/llm/online_evaluation_pairwise.py57Evaluate two models using an autorater. Args: inference_output_uri: Directory of model A's inference output. STRING
HIGH…nents/_implementation/llm/batch_prediction_pairwise.py58Runs up to two LLM Batch Prediction jobs side-by-side. Args: display_name: Display name for the batch prediction STRING
HIGH…cloud_pipeline_components/_implementation/llm/utils.py36Generates payload for a custom training job. Args: display_name: Component display name. Can contain up to 128 UTSTRING
HIGH…eline_components/_implementation/llm/function_based.py34Returns machine spec to use for a given accelerator_type. Args: accelerator_type: One of 'TPU' or 'GPU'. If 'TPU'STRING
HIGH…eline_components/_implementation/llm/function_based.py115Generates image uri based on base image name and accelerator type. Args: project: Project that contains the artifSTRING
HIGH…eline_components/_implementation/llm/function_based.py173Resolves reference model metadata needed by downstream components. Args: large_model_reference: User-provided refSTRING
HIGH…omponents/_implementation/llm/private_text_importer.py46Import a text dataset. Args: project: Project used to run the job. location: Location used to run the job. STRING
HIGH…n/model_evaluation/endpoint_batch_predict/component.py69Returns the batch prediction results for a given batch of instances. Args: project: Required. The GCP project tSTRING
HIGH…n/model_evaluation/endpoint_batch_predict/component.py173The First Party Model Endpoint Batch Predict Pipeline. Args: project: Required. The GCP project that runs the pipSTRING
HIGH…ure_attribution/feature_attribution_graph_component.py55A pipeline to compute feature attributions by sampling data for batch explanations. This pipeline guarantees support STRING
HIGH…odel_evaluation/feature_attribution_graph_component.py55A pipeline to compute feature attributions by sampling data for batch explanations. This pipeline guarantees support STRING
HIGH…_pipeline_components/preview/model_evaluation/utils.py28Creates a list of ModelEvaluationSlice.Slice.SliceSpec from a list of dictionary inputs. Args: list_of_feature_anSTRING
HIGH…_pipeline_components/preview/model_evaluation/utils.py84Creates a list of BiasConfig from a list of tuple inputs. Args: list_of_slice_a_and_slice_b: A list of slice_a_anSTRING
23 more matches not shown…
Decorative Section Separators150 hits · 375 pts
SeverityFileLineSnippetContext
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js96// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js98// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js131// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js133// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js161// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js163// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js288// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js290// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js396// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js398// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js702// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js704// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js1089// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/smoke-test-runner.js1091// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js194// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js196// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js247// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js249// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js333// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js335// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js380// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js382// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js464// ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/scripts/ui-smoke-test/cluster-manager.js466// ────────────────────────────────────────────────────────────────COMMENT
MEDIUM⚡…hon/kfp/kubeflow_client/backends/kubernetes/backend.py135 # ------------------------------------------------------------------COMMENT
MEDIUM⚡…hon/kfp/kubeflow_client/backends/kubernetes/backend.py137 # ------------------------------------------------------------------COMMENT
MEDIUM⚡…hon/kfp/kubeflow_client/backends/kubernetes/backend.py923 # ------------------------------------------------------------------COMMENT
MEDIUM⚡…hon/kfp/kubeflow_client/backends/kubernetes/backend.py925 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py272 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py274 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py573 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py575 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py634 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py636 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py710 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py712 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py804 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py806 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py1011 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py1013 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py1057 # ------------------------------------------------------------------COMMENT
MEDIUM…hon/kfp/kubeflow_client/backends/kubernetes/backend.py1059 # ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py295# ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py297# ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py315# ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py317# ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py1938# ------------------------------------------------------------------COMMENT
MEDIUM⚡…fp/kubeflow_client/backends/kubernetes/backend_test.py1940# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py60# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py62# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py85# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py87# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py123# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py125# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py238# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py240# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py412# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py414# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py515# ------------------------------------------------------------------COMMENT
MEDIUM…fp/kubeflow_client/backends/kubernetes/backend_test.py517# ------------------------------------------------------------------COMMENT
90 more matches not shown…
Magic Placeholder Names53 hits · 265 pts
SeverityFileLineSnippetContext
HIGHbackend/api/v2beta1/python_http_client/README.md55 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md45 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md121 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md197 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md273 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md349 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md425 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/ArtifactServiceApi.md515 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md52 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md130 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md208 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md284 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md362 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md448 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md526 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md606 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md684 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md764 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md854 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md932 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md1010 'authorization': 'YOUR_API_KEY'CODE
HIGH…d/api/v2beta1/python_http_client/docs/RunServiceApi.md1088 'authorization': 'YOUR_API_KEY'CODE
HIGH…pi/v2beta1/python_http_client/docs/ReportServiceApi.md40 'authorization': 'YOUR_API_KEY'CODE
HIGH…pi/v2beta1/python_http_client/docs/ReportServiceApi.md115 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md50 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md126 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md202 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md280 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md358 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md436 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md512 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md590 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md668 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md752 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md836 'authorization': 'YOUR_API_KEY'CODE
HIGH…/v2beta1/python_http_client/docs/PipelineServiceApi.md914 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md44 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md122 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md200 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md276 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md352 'authorization': 'YOUR_API_KEY'CODE
HIGH…eta1/python_http_client/docs/RecurringRunServiceApi.md428 'authorization': 'YOUR_API_KEY'CODE
HIGH…beta1/python_http_client/docs/DummyFilterServiceApi.md39 'authorization': 'YOUR_API_KEY'CODE
HIGH…a1/python_http_client/docs/PipelineUploadServiceApi.md40 'authorization': 'YOUR_API_KEY'CODE
HIGH…a1/python_http_client/docs/PipelineUploadServiceApi.md127 'authorization': 'YOUR_API_KEY'CODE
HIGH…i/v2beta1/python_http_client/docs/HealthzServiceApi.md39 'authorization': 'YOUR_API_KEY'CODE
HIGH…/api/v2beta1/python_http_client/docs/AuthServiceApi.md39 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md44 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md120 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md196 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md272 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md348 'authorization': 'YOUR_API_KEY'CODE
HIGH…2beta1/python_http_client/docs/ExperimentServiceApi.md432 'authorization': 'YOUR_API_KEY'CODE
Deep Nesting249 hits · 222 pts
SeverityFileLineSnippetContext
LOW…p-kubernetes-native-migration-tests/yaml_converters.py33CODE
LOWtest/seaweedfs/s3_helper.py127CODE
LOW…_pipelines/valid/pipeline_with_loops_and_conditions.py55CODE
LOW…a/sdk_compiled_pipelines/valid/if_elif_else_complex.py48CODE
LOWrelease/kfpr/steps.py519CODE
LOWrelease/kfpr/core.py648CODE
LOWrelease/kfpr/steps_test.py122CODE
LOWrelease/kfpr/steps_test.py235CODE
LOWrelease/kfpr/steps_test.py509CODE
LOWrelease/kfpr/steps_test.py1172CODE
LOWrelease/kfpr/steps_test.py1224CODE
LOWrelease/kfpr/steps_test.py1960CODE
LOW…erver/server/test/pipeline_plus_component/component.py35CODE
LOW…nts/v1/forecasting/prepare_data_for_train/component.py22CODE
LOW…ne_components/container/v1/aiplatform/remote_runner.py67CODE
LOW…nents/container/v1/wait_gcp_resources/remote_runner.py43CODE
LOW…ponents/container/v1/gcp_launcher/job_remote_runner.py147CODE
LOW…ts/container/v1/gcp_launcher/pipeline_remote_runner.py176CODE
LOW…omponents/container/v1/gcp_launcher/utils/json_util.py38CODE
LOW…omponents/container/v1/dataproc/utils/dataproc_util.py182CODE
LOW…plementation/llm/templated_custom_job/remote_runner.py52CODE
LOW…ementation/model_evaluation/import_model_evaluation.py153CODE
LOW…ementation/model_evaluation/import_model_evaluation.py383CODE
LOW…ementation/model_evaluation/import_model_evaluation.py496CODE
LOW…tation/model_evaluation/import_evaluated_annotation.py185CODE
LOW…ts/container/preview/gcp_launcher/job_remote_runner.py147CODE
LOW…ne_components/_implementation/llm/validate_pipeline.py24CODE
LOW…ponents/_implementation/llm/preprocess_chat_dataset.py21CODE
LOW…ponents/_implementation/llm/preprocess_chat_dataset.py163CODE
LOW…ponents/_implementation/llm/preprocess_chat_dataset.py210CODE
LOW…eline_components/_implementation/llm/function_based.py24CODE
LOW…_pipeline_components/preview/model_evaluation/utils.py23CODE
LOW…_pipeline_components/preview/model_evaluation/utils.py79CODE
LOW…ipeline_components/preview/automl/vision/json_utils.py125CODE
LOWsdk/python/test/test_utils/comparison_utils.py22CODE
LOWsdk/python/test/test_utils/file_utils.py31CODE
LOWsdk/python/kfp/init_test.py24CODE
LOWsdk/python/kfp/server_api/rest.py109CODE
LOWsdk/python/kfp/server_api/api_client.py218CODE
LOWsdk/python/kfp/server_api/api_client.py282CODE
LOWsdk/python/kfp/server_api/api_client.py384CODE
LOWsdk/python/kfp/server_api/api_client.py443CODE
LOWsdk/python/kfp/server_api/api_client.py473CODE
LOWsdk/python/kfp/server_api/api_client.py529CODE
LOW…python/kfp/server_api/models/artifact_artifact_type.py63CODE
LOW…ython/kfp/server_api/models/predicate_string_values.py76CODE
LOW…fp/server_api/models/v2beta1_list_artifact_response.py134CODE
LOW…/python/kfp/server_api/models/v2beta1_artifact_task.py234CODE
LOW…n/kfp/server_api/models/v2beta1_list_tasks_response.py128CODE
LOW…/python/kfp/server_api/models/v2beta1_runtime_state.py63CODE
LOW…on/kfp/server_api/models/v2beta1_list_runs_response.py134CODE
LOWsdk/python/kfp/server_api/models/protobuf_any.py137CODE
LOWsdk/python/kfp/server_api/models/v2beta1_artifact.py292CODE
LOW…server_api/models/v2beta1_find_cached_task_response.py76CODE
LOW…n/kfp/server_api/models/v2beta1_predicate_operation.py63CODE
LOWsdk/python/kfp/server_api/models/recurring_run_mode.py57CODE
LOW…erver_api/models/run_service_update_tasks_bulk_body.py76CODE
LOW…erver_api/models/v2beta1_update_tasks_bulk_response.py76CODE
LOW…/python/kfp/server_api/models/v2beta1_pipeline_task.py562CODE
LOW…p/server_api/models/v2beta1_list_pipelines_response.py134CODE
189 more matches not shown…
AI Structural Patterns162 hits · 155 pts
SeverityFileLineSnippetContext
LOW…_pipelines/valid/pipeline_with_loops_and_conditions.py51CODE
LOW…dk_compiled_pipelines/valid/xgboost_sample_pipeline.py77CODE
LOW…dk_compiled_pipelines/valid/xgboost_sample_pipeline.py192CODE
LOW…ompiled_pipelines/valid/create_pod_metadata_complex.py8CODE
LOW…d_pipelines/valid/essential/pipeline_with_condition.py25CODE
LOW…nes/valid/essential/pipeline_with_nested_conditions.py25CODE
LOWrelease/kfpr/cli.py169CODE
LOWrelease/kfpr/cli.py437CODE
LOW…2beta1/python_http_client_smoke/test_task_endpoints.py52CODE
LOW…/v2/driver/test_data/component_with_optional_inputs.py22CODE
LOWbackend/src/v2/driver/test_data/k8s_parameters.py337CODE
LOWsamples/core/condition/condition_v2.py30CODE
LOWsamples/core/condition/nested_condition.py23CODE
LOW…line_components/v1/dataflow/flex_template/component.py26CODE
LOW…oogle_cloud_pipeline_components/v1/custom_job/utils.py74CODE
LOW…e_cloud_pipeline_components/v1/custom_job/component.py24CODE
LOW…s/v1/model_evaluation/evaluated_annotation_pipeline.py30CODE
LOW…_evaluation/evaluation_llm_text_generation_pipeline.py33CODE
LOW…onents/v1/model_evaluation/classification_component.py27CODE
LOW…luation/evaluation_automl_unstructure_data_pipeline.py31CODE
LOW…luation/evaluation_automl_unstructure_data_pipeline.py200CODE
LOW…luation/evaluation_automl_unstructure_data_pipeline.py362CODE
LOW…ponents/v1/model_evaluation/error_analysis_pipeline.py32CODE
LOW…omponents/v1/model_evaluation/forecasting_component.py27CODE
LOW…model_evaluation/evaluation_automl_tabular_pipeline.py29CODE
LOW…model_evaluation/evaluation_automl_tabular_pipeline.py170CODE
LOW…model_evaluation/evaluation_automl_tabular_pipeline.py304CODE
LOW…l_evaluation/evaluation_llm_classification_pipeline.py35CODE
LOW…luation_automl_tabular_feature_attribution_pipeline.py32CODE
LOW…luation_automl_tabular_feature_attribution_pipeline.py210CODE
LOW…luation_automl_tabular_feature_attribution_pipeline.py382CODE
LOW…_evaluation/evaluation_feature_attribution_pipeline.py31CODE
LOW…_evaluation/evaluation_feature_attribution_pipeline.py243CODE
LOW…_evaluation/evaluation_feature_attribution_pipeline.py451CODE
LOW…components/v1/model_evaluation/regression_component.py27CODE
LOW…model_based_llm_evaluation/autosxs/autosxs_pipeline.py38CODE
LOW…ine_components/v1/bigquery/evaluate_model/component.py30CODE
LOW…line_components/v1/bigquery/predict_model/component.py30CODE
LOW…ponents/v1/bigquery/explain_predict_model/component.py29CODE
LOW…omponents/v1/bigquery/ml_confusion_matrix/component.py30CODE
LOW…ine_components/v1/bigquery/forecast_model/component.py30CODE
LOW…onents/v1/bigquery/explain_forecast_model/component.py30CODE
LOW…onents/v1/bigquery/ml_reconstruction_loss/component.py29CODE
LOW…eline_components/v1/bigquery/ml_roc_curve/component.py30CODE
LOW…eline_components/v1/bigquery/ml_recommend/component.py30CODE
LOW…onents/v1/bigquery/detect_anomalies_model/component.py30CODE
LOW…pipeline_components/v1/automl/tabular/stage_1_tuner.py26CODE
LOW…_components/v1/automl/tabular/stats_and_example_gen.py26CODE
LOW…/automl/tabular/training_configurator_and_validator.py23CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py36CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py407CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py633CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py763CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py1055CODE
LOW…e_cloud_pipeline_components/v1/automl/tabular/utils.py1248CODE
LOW…ne_components/v1/automl/forecasting/prophet_trainer.py26CODE
LOW…oud_pipeline_components/v1/automl/forecasting/utils.py10CODE
LOW…oud_pipeline_components/v1/automl/forecasting/utils.py135CODE
LOW…/training_job/automl_tabular_training_job/component.py27CODE
LOW…ining_job/automl_forecasting_training_job/component.py27CODE
102 more matches not shown…
Empty Error Handlers24 hits · 120 pts
SeverityFileLineSnippetContext
HIGHrelease/kfpr/core.py183except OSError:CODE
HIGH…d_pipeline_components/container/v1/aiplatform/utils.py59except ImportError:CODE
HIGH…ne_components/container/v1/aiplatform/remote_runner.py231except:CODE
HIGHsdk/python/kfp/cli/utils/parsing.py36except (json.JSONDecodeError, ValueError):CODE
HIGHsdk/python/kfp/cli/utils/parsing.py46except ValueError:CODE
HIGHsdk/python/kfp/cli/utils/parsing.py51except ValueError:CODE
HIGHsdk/python/kfp/local/io.py109except ValueError:CODE
HIGHsdk/python/kfp/local/io.py100except ValueError:CODE
HIGHsdk/python/kfp/local/docker_task_handler.py150except docker.errors.NotFound:CODE
HIGHsdk/python/kfp/local/docker_task_handler_test.py354except FileNotFoundError:CODE
HIGHsdk/python/kfp/local/docker_task_handler_test.py384except FileNotFoundError:CODE
HIGHsdk/python/kfp/local/docker_task_handler_test.py408except FileNotFoundError:CODE
HIGHsdk/python/kfp/local/orchestrator/task_spec_utils.py238except Exception:CODE
HIGHsdk/python/kfp/local/orchestrator/task_spec_utils.py255except Exception:CODE
HIGHsdk/python/kfp/local/orchestrator/task_spec_utils.py251except Exception:CODE
HIGH…ython/kfp/kubeflow_client/backends/kubernetes/utils.py137except FileNotFoundError:CODE
HIGHsdk/python/kfp/dsl/templates/notebook_executor.py68except Exception:CODE
HIGHsdk/python/kfp/dsl/templates/notebook_executor.py87except Exception:CODE
HIGH.github/resources/scripts/service_path_probe.py237except OSError:CODE
HIGH.github/resources/scripts/service_path_probe.py229except OSError:CODE
HIGH.github/resources/scripts/network_window.py582except OSError:CODE
HIGH.github/resources/scripts/network_window.py590except OSError:CODE
HIGH.github/resources/scripts/network_window.py596except OSError:CODE
HIGH…stalls/multi-user/pipelines-profile-controller/sync.py356except Exception:CODE
Structural Annotation Overuse64 hits · 109 pts
SeverityFileLineSnippetContext
LOW⚡CONTRIBUTING.md17### Step 1: Establish ContextCOMMENT
LOW⚡CONTRIBUTING.md27### Step 2: Create Feature RequestCOMMENT
LOW⚡CONTRIBUTING.md34### Step 3: Initial Team TriageCOMMENT
LOWCONTRIBUTING.md45### Step 4: Design ReviewCOMMENT
LOWCONTRIBUTING.md60### Step 5: ImplementationCOMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js491 // Step 3: Ensure Kind cluster (always needed — frontend server proxies through it)COMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js500 // Step 4: Build/deploy changed backend componentsCOMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js517 // Step 5: Re-apply manifestsCOMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js527 // Step 6: Set up port forwarding + frontend serverCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js428 // Step 1: Check port availability (Issue 6)COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js441 // Step 2: Detect changesCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js541 // Step 7: Seed dataCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js557 // Step 8: Fetch PR code (if --pr in compare mode)COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js584 // Step 9: Check out base ref via git worktree and build its frontendCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js612 // Step 10: Build PR frontendCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js628 // Step 11: Serve both via proxy-server.js → API proxied to localhost:3001COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js657 // Step 12: Capture screenshots + generate comparisonCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go30 // Step 1: Create test context with root DAG already executedCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go37 // Step 2: Run driver for a taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go73 // Step 1: Create test context with root DAG already executedCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go80 // Step 2: Run driver for producer taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go169 // Step 1: Run driver for producer taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go175 // Step 2: Run launcher and mock output parameter creationCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go238 // Step 1: Enter the secondary pipelineCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go241 // Step 2: Run the task that produces input for the loopCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go257 // Step 3: Run loop DAG driverCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go263 // Step 4: Run loop iterationsCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go49 // Step 3: Run launcher using Execute() which tests the full flow including:COMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go94 // Step 3: Run launcher to simulate actual component executionCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go125 // Step 4: Run driver for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go141 // Step 5: Run launcher for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go203 // Step 3: Run driver for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go214 // Step 4: Run launcher for consumerCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go291 // Step 5: Exit loop DAGCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go456 // Step 1: Create mock KFP APICOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go459 // Step 2: Create test run and taskCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go551 // Step 5: Create task specCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go558 // Step 6: Create launcher optionsCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go573 // Step 7: Create launcher with client managerCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go583 // Step 8: Setup mocks for dependenciesCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go598 // Step 9: Inject mocks into launcherCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go603 // Step 10: Execute the launcher's internal execute methodCOMMENT
LOWbackend/src/v2/component/launcher_v2_test.go484 // Step 3: Create executor input with inputs and outputsCOMMENT
LOWbackend/src/v2/component/launcher_v2_test.go533 // Step 4: Create component specCOMMENT
LOWbackend/src/v2/component/batch_updater.go303 // Step 1: Create artifacts using bulk APICOMMENT
LOWbackend/src/v2/component/batch_updater.go350 // Step 2: Create artifact-tasks using existing bulk APICOMMENT
LOWbackend/src/v2/component/batch_updater.go379 // Step 3: Update tasks using bulk API after artifact links exist.COMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go837 // Step 2: block upgrade if legacy data too longCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go842 // Step 3: drop all foreign key constraints which can block shrinking columnsCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go851 // Step 4: shrink fields to meet new length constraintsCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go884 // Step 6: Run autoMigrate to add any missing FKs/constraints/columns/indexes andCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go892 // Step 7: Data backfill for pipeline_versions if this is the first time forCOMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go825 // Step 1: decide whether to backfill pipeline_versionsCOMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go1730 // Step 1: duplicate pipelines to pipeline versions.COMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go1762 // Step 2: modifiy pipelines table after pipeline_versions are populated.COMMENT
LOWbackend/src/apiserver/config/config_test.go707 // Step 1: Load with empty namespace — pipeline stored with Namespace = ""COMMENT
LOW⚡backend/src/apiserver/config/config_test.go728 // Step 2: Switch to non-empty namespace and add a new versionCOMMENT
LOW⚡backend/src/apiserver/config/config_test.go735 // Step 3: Assert: the new version was created under the existing pipelineCOMMENT
LOWbackend/src/apiserver/config/config_test.go746 // Step 1: Load with empty namespaceCOMMENT
LOW⚡backend/src/apiserver/config/config_test.go767 // Step 2: Switch namespace but keep same version nameCOMMENT
4 more matches not shown…
Verbosity Indicators56 hits · 95 pts
SeverityFileLineSnippetContext
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js491 // Step 3: Ensure Kind cluster (always needed — frontend server proxies through it)COMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js500 // Step 4: Build/deploy changed backend componentsCOMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js517 // Step 5: Re-apply manifestsCOMMENT
LOW⚡frontend/scripts/ui-smoke-test/smoke-test-runner.js527 // Step 6: Set up port forwarding + frontend serverCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js428 // Step 1: Check port availability (Issue 6)COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js441 // Step 2: Detect changesCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js541 // Step 7: Seed dataCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js557 // Step 8: Fetch PR code (if --pr in compare mode)COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js584 // Step 9: Check out base ref via git worktree and build its frontendCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js612 // Step 10: Build PR frontendCOMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js628 // Step 11: Serve both via proxy-server.js → API proxied to localhost:3001COMMENT
LOWfrontend/scripts/ui-smoke-test/smoke-test-runner.js657 // Step 12: Capture screenshots + generate comparisonCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go30 // Step 1: Create test context with root DAG already executedCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go37 // Step 2: Run driver for a taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go73 // Step 1: Create test context with root DAG already executedCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go80 // Step 2: Run driver for producer taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go169 // Step 1: Run driver for producer taskCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go175 // Step 2: Run launcher and mock output parameter creationCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go238 // Step 1: Enter the secondary pipelineCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go241 // Step 2: Run the task that produces input for the loopCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go257 // Step 3: Run loop DAG driverCOMMENT
LOW⚡…end/src/v2/driver/launcher_integration_example_test.go263 // Step 4: Run loop iterationsCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go49 // Step 3: Run launcher using Execute() which tests the full flow including:COMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go94 // Step 3: Run launcher to simulate actual component executionCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go125 // Step 4: Run driver for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go141 // Step 5: Run launcher for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go203 // Step 3: Run driver for consumer taskCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go214 // Step 4: Run launcher for consumerCOMMENT
LOW…end/src/v2/driver/launcher_integration_example_test.go291 // Step 5: Exit loop DAGCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go456 // Step 1: Create mock KFP APICOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go459 // Step 2: Create test run and taskCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go551 // Step 5: Create task specCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go558 // Step 6: Create launcher optionsCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go573 // Step 7: Create launcher with client managerCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go583 // Step 8: Setup mocks for dependenciesCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go598 // Step 9: Inject mocks into launcherCOMMENT
LOW⚡backend/src/v2/component/launcher_v2_test.go603 // Step 10: Execute the launcher's internal execute methodCOMMENT
LOWbackend/src/v2/component/launcher_v2_test.go484 // Step 3: Create executor input with inputs and outputsCOMMENT
LOWbackend/src/v2/component/launcher_v2_test.go533 // Step 4: Create component specCOMMENT
LOWbackend/src/v2/component/batch_updater.go303 // Step 1: Create artifacts using bulk APICOMMENT
LOWbackend/src/v2/component/batch_updater.go350 // Step 2: Create artifact-tasks using existing bulk APICOMMENT
LOWbackend/src/v2/component/batch_updater.go379 // Step 3: Update tasks using bulk API after artifact links exist.COMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go837 // Step 2: block upgrade if legacy data too longCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go842 // Step 3: drop all foreign key constraints which can block shrinking columnsCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go851 // Step 4: shrink fields to meet new length constraintsCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go884 // Step 6: Run autoMigrate to add any missing FKs/constraints/columns/indexes andCOMMENT
LOW⚡backend/src/apiserver/client_manager/client_manager.go892 // Step 7: Data backfill for pipeline_versions if this is the first time forCOMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go825 // Step 1: decide whether to backfill pipeline_versionsCOMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go1730 // Step 1: duplicate pipelines to pipeline versions.COMMENT
LOWbackend/src/apiserver/client_manager/client_manager.go1762 // Step 2: modifiy pipelines table after pipeline_versions are populated.COMMENT
LOWbackend/src/apiserver/config/config_test.go707 // Step 1: Load with empty namespace — pipeline stored with Namespace = ""COMMENT
LOW⚡backend/src/apiserver/config/config_test.go728 // Step 2: Switch to non-empty namespace and add a new versionCOMMENT
LOW⚡backend/src/apiserver/config/config_test.go735 // Step 3: Assert: the new version was created under the existing pipelineCOMMENT
LOWbackend/src/apiserver/config/config_test.go746 // Step 1: Load with empty namespaceCOMMENT
LOW⚡backend/src/apiserver/config/config_test.go767 // Step 2: Switch namespace but keep same version nameCOMMENT
LOW⚡backend/src/apiserver/config/config_test.go773 // Step 3: Assert: no duplicate version was createdCOMMENT
Excessive Try-Catch Wrapping73 hits · 86 pts
SeverityFileLineSnippetContext
LOWtools/k8s-native/migration.py215 except Exception as e:CODE
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py165 print(f"Error: Pipeline file not found: {file_path}")CODE
MEDIUM…led_pipelines/valid/pipeline_with_task_final_status.py28 print('Error code: ', status.error_code)CODE
MEDIUM…led_pipelines/valid/pipeline_with_task_final_status.py29 print('Error message: ', status.error_message)CODE
MEDIUM…d_pipelines/valid/pipeline_with_task_final_status.yaml89 \ code: ', status.error_code)\n print('Error message: ', status.error_message)\n\CODE
LOW…ompiled_pipelines/valid/integration/ray_integration.py34 except Exception as e:CODE
LOW…ompiled_pipelines/valid/integration/ray_integration.py68 except Exception as e:CODE
LOW…ompiled_pipelines/valid/integration/ray_integration.py109 except Exception as e:CODE
LOW…ompiled_pipelines/valid/integration/ray_integration.py140 except Exception as e2:CODE
LOW…ompiled_pipelines/valid/integration/ray_integration.py144 except Exception as e:CODE
LOW…pelines/valid/critical/pipeline_with_submit_request.py27 except Exception as e:CODE
LOW…piled_pipelines/valid/essential/embedded_artifact.yaml44 except Exception as __kfp_e:\n raise RuntimeError(f'Failed to extract\CODE
LOW…piled_pipelines/valid/essential/embedded_artifact.yaml87 except Exception as __kfp_e:\n raise RuntimeError(f'Failed to extract\CODE
LOWdocs/user-guides/core-functions/connect-api.md317 except Exception as ex:CODE
MEDIUMdocs/user-guides/core-functions/connect-api.md314def _create_kfp_client(self) -> kfp.Client:CODE
MEDIUMdocs/user-guides/core-functions/control-flow.md295 print('Error code: ', status.error_code)CODE
MEDIUMdocs/user-guides/core-functions/control-flow.md296 print('Error message: ', status.error_message)CODE
LOW…ne_components/_implementation/llm/validate_pipeline.py120 except Exception as e: # pylint: disable=broad-exception-caughtCODE
LOW…ine_components/_implementation/llm/upload_llm_model.py122 except Exception as e: # pylint: disable=broad-exception-caughtCODE
LOW…ine_components/_implementation/llm/deploy_llm_model.py135 except Exception as e: # pylint: disable=broad-exception-caughtCODE
LOWsdk/python/test/local_execution/local_execution_test.py392 except Exception as e:CODE
LOWsdk/python/test/local_execution/local_execution_test.py435 except Exception as e:CODE
MEDIUMsdk/python/test/test_utils/file_utils.py51 print(f'Error parsing YAML file: {ex}')CODE
LOWsdk/python/kfp/cli/compile_.py264 except Exception as e:CODE
LOWsdk/python/kfp/cli/__main__.py26 except Exception as e:CODE
LOWsdk/python/kfp/local/cache.py151 except Exception:CODE
LOWsdk/python/kfp/local/pip_install_serialization_test.py291 except Exception as e:CODE
LOWsdk/python/kfp/local/pip_install_manager.py183 except Exception as e:CODE
LOWsdk/python/kfp/local/executor_output_utils.py132 except Exception as e:CODE
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py92 except Exception:CODE
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py201 except Exception as e:CODE
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py303 except Exception as e:CODE
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py400 except Exception:CODE
LOWsdk/python/kfp/local/orchestrator/task_spec_utils.py110 except Exception as exc:CODE
LOWsdk/python/kfp/local/orchestrator/task_spec_utils.py238 except Exception:CODE
LOW⚡sdk/python/kfp/local/orchestrator/task_spec_utils.py251 except Exception:CODE
LOW⚡sdk/python/kfp/local/orchestrator/task_spec_utils.py255 except Exception:CODE
LOWsdk/python/kfp/local/orchestrator/task_executor.py166 except Exception as exc: # pragma: no cover - defensiveCODE
LOWsdk/python/kfp/local/orchestrator/orchestrator_utils.py84 except Exception as e:CODE
LOW⚡…hon/kfp/kubeflow_client/backends/kubernetes/backend.py129 except Exception as e:CODE
LOW…hon/kfp/kubeflow_client/backends/kubernetes/backend.py897 except Exception as error:CODE
LOW…hon/kfp/kubeflow_client/backends/kubernetes/backend.py945 except Exception as error:CODE
LOW…ython/kfp/kubeflow_client/backends/kubernetes/utils.py58 except Exception: # pylint: disable=broad-exceptCODE
LOWsdk/python/kfp/client/auth.py56 except Exception as e:CODE
LOWsdk/python/kfp/client/client.py308 except Exception as e:CODE
LOWsdk/python/kfp/client/client.py325 except Exception as e:CODE
LOWsdk/python/kfp/client/client.py407 except Exception:CODE
LOWsdk/python/kfp/dsl/component_factory.py684except Exception as __kfp_e:CODE
MEDIUMsdk/python/kfp/dsl/task_final_status.py35 print('Error code: ', status.error_code)STRING
MEDIUMsdk/python/kfp/dsl/task_final_status.py36 print('Error message: ', status.error_message)STRING
LOWsdk/python/kfp/dsl/templates/notebook_executor.py68 except Exception:CODE
LOWsdk/python/kfp/dsl/templates/notebook_executor.py87 except Exception:CODE
LOWsdk/python/kfp/dsl/templates/notebook_executor.py92 except Exception:CODE
LOWsdk/python/kfp/dsl/templates/notebook_executor.py152 except Exception as e:CODE
LOWsdk/python/kfp/dsl/templates/notebook_executor.py175 except Exception as e:CODE
LOWsdk/python/kfp/dsl/templates/notebook_executor.py243except Exception as __kfp_e:CODE
LOW.github/resources/scripts/runner-telemetry.sh243except Exception:CODE
LOW.github/resources/scripts/ci_health_report.py351 except Exception: # noqa: BLE001 - best-effort artifact ingestionCODE
MEDIUM…ithub/resources/scripts/kfp-readiness/wait_for_pods.py88 print(f"An error occurred while running kubectl get pods: {e.stderr}")CODE
LOW.github/scripts/kubeflow_membership.py105 except Exception as error:CODE
13 more matches not shown…
Fake / Example Data76 hits · 72 pts
SeverityFileLineSnippetContext
LOWfrontend/server/app.test.ts288 .set('Kubeflow-Userid', 'test-user@example.org')CODE
LOWfrontend/server/app.test.ts295 expect(receivedHeaders['kubeflow-userid']).toBe('test-user@example.org');CODE
LOWfrontend/server/app.test.ts661 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/app.test.ts666 user: 'user@example.com',CODE
LOW…ontend/server/integration-tests/artifact-proxy.test.ts473 .set('kubeflow-userid', 'user@example.com')CODE
LOW⚡frontend/server/integration-tests/artifact-auth.test.ts1039 .set('kubeflow-userid', 'user@example.com')CODE
LOW⚡frontend/server/integration-tests/artifact-auth.test.ts1047 .set('kubeflow-userid', 'user@example.com')CODE
LOW⚡frontend/server/integration-tests/artifact-auth.test.ts1055 { 'kubeflow-userid': 'user@example.com' },CODE
LOW⚡frontend/server/integration-tests/artifact-auth.test.ts1062 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts200 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts275 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts313 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts357 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts395 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts431 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts524 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts602 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts626 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts642 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts656 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts673 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts689 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts705 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts727 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts746 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts765 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts785 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts793 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts805 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts825 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts853 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts874 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts888 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts906 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts913 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts927 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts935 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts950 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts957 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts970 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts977 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts989 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts996 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1016 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1023 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1077 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1084 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1099 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1106 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1124 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1143 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1164 .set('kubeflow-userid', 'user@example.com')CODE
LOWfrontend/server/integration-tests/artifact-auth.test.ts1172 { 'kubeflow-userid': 'user@example.com' },CODE
LOWfrontend/server/helpers/artifact-validator.test.ts226 'kubeflow-userid': 'user@example.com',CODE
LOWfrontend/server/helpers/artifact-validator.test.ts237 expect(new Headers(requestInit.headers).get('kubeflow-userid')).toBe('user@example.com');CODE
LOW…backend/data/v2/pipeline/protobuf_value_params_v2.json49 "\nimport kfp\nfrom kfp import dsl\nfrom kfp.dsl import *\nfrom typing import *\n\ndef print_params(\n CODE
LOW⚡frontend/src/components/DetailsTable.test.tsx95 `Lorem Ipsum is simply dummy text of the printing and typesettingCODE
LOW⚡frontend/src/components/DetailsTable.test.tsx96 industry. Lorem Ipsum has been the industry's standard dummy text everCODE
LOW⚡frontend/src/components/DetailsTable.test.tsx101 of Letraset sheets containing Lorem Ipsum passages, and more recentlyCODE
LOW⚡frontend/src/components/DetailsTable.test.tsx103 of Lorem Ipsum.`,CODE
16 more matches not shown…
Modern Structural Boilerplate58 hits · 58 pts
SeverityFileLineSnippetContext
LOWrelease/kfpr/steps.py470def _update_sdk_docs_versions(path: Path, version: str) -> None:CODE
LOWrelease/kfpr/steps.py493def _update_kfp_kubernetes_docs_versions(path: Path, version: str) -> None:STRING
LOWrelease/kfpr/steps.py618def _update_uv_package_versions(root: Path, sdk_version: str) -> None:STRING
LOWrelease/kfpr/steps.py683def _update_sdk_version_files(context: ReleaseContext) -> None:STRING
LOWrelease/kfpr/cli.py42def _set_answer(state: ReleaseState, key: str, value: object | None) -> None:CODE
LOW…ogle_cloud_pipeline_components/v1/dataflow/__init__.py21__all__ = [CODE
LOW…le_cloud_pipeline_components/v1/custom_job/__init__.py22__all__ = [CODE
LOW…ud_pipeline_components/v1/model_evaluation/__init__.py29__all__ = [CODE
LOW…odel_evaluation/model_based_llm_evaluation/__init__.py18__all__ = [CODE
LOW…ne_components/v1/vertex_notification_email/__init__.py18__all__ = [CODE
LOW…oogle_cloud_pipeline_components/v1/dataset/__init__.py33__all__ = [CODE
LOW…ogle_cloud_pipeline_components/v1/bigquery/__init__.py45__all__ = [CODE
LOW…loud_pipeline_components/v1/automl/tabular/__init__.py31__all__ = [CODE
LOW…_pipeline_components/v1/automl/forecasting/__init__.py23__all__ = [CODE
LOW…pipeline_components/v1/automl/training_job/__init__.py23__all__ = [CODE
LOW…ne_components/v1/hyperparameter_tuning_job/__init__.py22__all__ = [CODE
LOW…_pipeline_components/v1/wait_gcp_resources/__init__.py20__all__ = [CODE
LOW…ogle_cloud_pipeline_components/v1/endpoint/__init__.py23__all__ = [CODE
LOW…/google_cloud_pipeline_components/v1/model/__init__.py23__all__ = [CODE
LOW…e_cloud_pipeline_components/v1/forecasting/__init__.py22__all__ = [CODE
LOW…d_pipeline_components/v1/batch_predict_job/__init__.py20__all__ = [CODE
LOW…ogle_cloud_pipeline_components/v1/dataproc/__init__.py23__all__ = [CODE
LOW…ogle_cloud_pipeline_components/types/artifact_types.py27__all__ = [CODE
LOW…omponents/_implementation/model_evaluation/__init__.py39__all__ = [CODE
LOW…line_components/_implementation/starry_net/__init__.py28__all__ = [CODE
LOW…_pipeline_components/_implementation/model/__init__.py19__all__ = [CODE
LOW…cloud_pipeline_components/preview/dataflow/__init__.py18__all__ = [CODE
LOW…oud_pipeline_components/preview/custom_job/__init__.py34__all__ = [CODE
LOW…ogle_cloud_pipeline_components/preview/llm/__init__.py20__all__ = [CODE
LOW…peline_components/preview/model_evaluation/__init__.py22__all__ = [CODE
LOW…pipeline_components/preview/automl/tabular/__init__.py22__all__ = [CODE
LOW…line_components/preview/automl/forecasting/__init__.py27__all__ = [CODE
LOW…oud_pipeline_components/preview/starry_net/__init__.py19__all__ = ['starry_net']CODE
LOWsdk/python/kfp/server_api/rest.py30logger = logging.getLogger(__name__)CODE
LOWsdk/python/kfp/local/__init__.py21__all__ = [CODE
LOWsdk/python/kfp/local/pip_install_manager.py23logger = logging.getLogger(__name__)CODE
LOWsdk/python/kfp/components/__init__.py17__all__ = [CODE
LOWsdk/python/kfp/registry/__init__.py17__all__ = [CODE
LOWsdk/python/kfp/kubeflow_client/constants.py16__all__ = [CODE
LOWsdk/python/kfp/kubeflow_client/__init__.py33__all__ = [CODE
LOWsdk/python/kfp/kubeflow_client/types.py22__all__ = [CODE
LOW…python/kfp/kubeflow_client/backends/kubernetes/auth.py24logger = logging.getLogger(__name__)CODE
LOW…hon/kfp/kubeflow_client/backends/kubernetes/backend.py50logger = logging.getLogger(__name__)CODE
LOW…on/kfp/kubeflow_client/backends/kubernetes/__init__.py20__all__ = ['KubernetesBackend', 'KubernetesBackendConfig']CODE
LOW…ython/kfp/kubeflow_client/backends/kubernetes/utils.py24logger = logging.getLogger(__name__)CODE
LOWsdk/python/kfp/kubeflow_client/api/pipelines_client.py39__all__ = ['PipelinesClient']CODE
LOWsdk/python/kfp/kubeflow_client/api/__init__.py18__all__ = ['PipelinesClient']CODE
LOWsdk/python/kfp/kubernetes/__init__.py17__all__ = [CODE
LOWsdk/python/kfp/client/client.py417 def set_user_namespace(self, namespace: str) -> None:CODE
LOWsdk/python/kfp/client/__init__.py16__all__ = [CODE
LOWsdk/python/kfp/compiler/__init__.py17__all__ = [CODE
LOWsdk/python/kfp/dsl/__init__.py18__all__ = [CODE
LOW⚡sdk/python/kfp/dsl/types/artifact_types.py132 def _set_path(self, path: str) -> None:CODE
LOW⚡sdk/python/kfp/dsl/types/artifact_types.py135 def _set_custom_path(self, value: str) -> None:CODE
LOW⚡sdk/python/kfp/dsl/types/artifact_types.py142 def set_path(self, path: str) -> None:CODE
LOWsdk/python/kfp/dsl/types/artifact_types.py198 def _set_framework(self, framework: str) -> None:CODE
LOWsdk/python/kfp/dsl/types/artifact_types.py285 def set_confusion_matrix_categories(self, categories: List[str]) -> None:CODE
LOWsdk/python/kfp/dsl/types/artifact_types.py411 def _update_metadata(self, slice: str) -> None:CODE
Self-Referential Comments14 hits · 41 pts
SeverityFileLineSnippetContext
MEDIUMtools/k8s-native/migration.py129 # Create the Pipeline objectCOMMENT
MEDIUMtools/k8s-native/migration.py146 # Create a PipelineVersion object for each versionCOMMENT
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py114 # Create the runCOMMENT
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py136 # Create the recurring runCOMMENT
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py178 # Create a version for the first pipelineCOMMENT
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py229 # Create a run with the hello-world pipelineCOMMENT
MEDIUM…rnetes-native-migration-tests/create_test_pipelines.py241 # Create a recurring run with the add-numbers pipeline (using v1)COMMENT
MEDIUM…ed_pipelines/valid/critical/pipeline_with_workspace.py24 # Create a file in the workspaceCOMMENT
MEDIUM…_pipelines/valid/critical/pipeline_with_workspace.yaml91 \ a file to the workspace.\"\"\" \n import os\n\n # Create a file\CODE
MEDIUMbackend/conformance/run.sh13# Create the done file.COMMENT
MEDIUMsamples/core/tfx-oss/utils/taxi_utils.py349 # Create an input receiver for TFMA processingCOMMENT
MEDIUM…omponents/container/v1/dataproc/utils/dataproc_util.py293 # Create the Batch resource.COMMENT
MEDIUMsdk/python/kfp/local/subprocess_task_handler.py189 # Create the virtual environment inside the temporary directoryCOMMENT
MEDIUMsdk/python/kfp/dsl/templates/notebook_executor.py203 # Define the streaming client class inline in the generated source to avoidCOMMENT
Redundant / Tautological Comments17 hits · 26 pts
SeverityFileLineSnippetContext
LOW…native-migration-tests/kfp_k8s_mode_migration_tests.py453 # Check if the recurring run still exists via APICOMMENT
LOW…iled_pipelines/valid/pipeline_with_secret_as_volume.py30 # Check if the secret existsCOMMENT
LOW…ed_pipelines/valid/pipeline_with_secret_as_volume.yaml37 \ \"username\")\n\n # Check if the secret exists\n if not os.path.exists(username_path):\n\CODE
LOW…ponents/_implementation/llm/preprocess_chat_dataset.py308 # Write file pattern that the tokenizer can use to find all processed files.COMMENT
LOWsdk/python/test/local_execution/local_execution_test.py373 # Set permissions to be writable by all (needed for Docker)COMMENT
LOWsdk/python/kfp/local/subprocess_task_handler.py58 # Check if command contains pip install operationsCOMMENT
LOWsdk/python/kfp/local/docker_task_handler.py90 # Check if command contains pip install operationsCOMMENT
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py78 # Check if this is a task output referenceCOMMENT
LOW⚡…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py331 # Check if the iterator has valid items configurationCOMMENT
LOW⚡…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py337 # Check if the iterator has valid items configurationCOMMENT
LOWsdk/python/kfp/local/orchestrator/orchestrator_utils.py159 # Check if there's a parameter expression selector to applyCOMMENT
LOWsdk/python/kfp/registry/registry_client.py243 # Check if it's a known hostCOMMENT
LOWsdk/python/kfp/compiler/pipeline_spec_builder.py2264 # Check if a platform has a workspace configCOMMENT
LOWsdk/python/kfp/dsl/types/type_annotations.py287 # Check if the annotation has '__args__' attributeCOMMENT
LOW.github/resources/scripts/deploy-kfp.sh271# Check if all pods are running - (10 minutes)COMMENT
LOW…stalls/multi-user/pipelines-profile-controller/sync.py222 # Check if there are any enabled rulesCOMMENT
LOW…stalls/multi-user/pipelines-profile-controller/sync.py549 # Check if secret is already there when the controller made the request. If yes, thenCOMMENT
AI Slop Vocabulary15 hits · 24 pts
SeverityFileLineSnippetContext
LOW…pipeline/lightweight_python_functions_v2_pipeline.json108 "\nfrom kfp.dsl import *\nfrom typing import *\n\ndef preprocess(\n # An input parameter of type string.\CODE
LOW…line/lightweight_python_functions_v2_pipeline_rev.yaml49 \ f:\n f.write(message)\n\n # OutputPath is used to just pass\CODE
LOWfrontend/src/lib/v2/WorkflowUtils.test.ts119 "\nimport kfp\nfrom kfp import dsl\nfrom kfp.dsl import *\nfrom typing import *\n\ndef preprocess(\n # An inpCODE
LOW…test/lightweight_python_functions_v2_pipeline_rev.yaml49 \ f:\n f.write(message)\n\n # OutputPath is used to just pass\CODE
LOWtest_data/sdk_compiled_pipelines/valid/preprocess.py53 # OutputPath is used to just pass the local file path of the output artifactCOMMENT
LOWtest_data/sdk_compiled_pipelines/valid/preprocess.yaml90 \ f:\n f.write(message)\n\n # OutputPath is used to just pass\CODE
LOW…lid/essential/lightweight_python_functions_pipeline.py58 # OutputPath is used to just pass the local file path of the output artifactCOMMENT
LOW…d/essential/lightweight_python_functions_pipeline.yaml112 \ f:\n f.write(message)\n\n # OutputPath is used to just pass\CODE
LOW…_pipelines/lightweight_python_functions_v2_pipeline.py55 # OutputPath is used to just pass the local file path of the output artifactCOMMENT
MEDIUMbackend/src/v2/objectstore/object_store.go62 // Use s3blob.OpenBucketV2 with the configured S3 client to leverage retry logic.COMMENT
MEDIUMbackend/src/common/util/execution_spec.go226// leverage the existing Workflow creation for Argo. Need to supportCOMMENT
LOW…omponents/Data passing in python components - Files.py66 # OutputPath is used to just pass the local file path of the output artifactCOMMENT
MEDIUMsdk/python/kfp/local/placeholder_utils_test.py79 # for comprehensive testing, but in practice metadataCOMMENT
LOWsdk/python/kfp/dsl/executor_test.py253 # Test that output parameters just use the passed in filename.STRING
MEDIUM…kustomize/third-party/mysql/base/mysql-deployment.yaml45 # Disable binlog as the logs grow fast and eat up all disk spaces eventually. And KFP doesn't currently utilize COMMENT
Hallucination Indicators1 hit · 10 pts
SeverityFileLineSnippetContext
CRITICAL.github/resources/scripts/ci_base_workflows_test.py106 fixture.response.repository.object.entries.filter(entry => !fixture.missing.includes(entry.name))CODE
Overly Generic Function Names3 hits · 3 pts
SeverityFileLineSnippetContext
LOWsdk/python/kfp/cli/utils/parsing_test.py53 def test_function(self):CODE
LOWsdk/python/kfp/local/pip_install_serialization_test.py87 def process_data(value: int) -> int:CODE
LOW…on/kfp/local/orchestrator/enhanced_dag_orchestrator.py711def execute_task(CODE
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOWsdk/python/kfp/compiler/pipeline_spec_builder.py2091 # TODO: add validation of returned outputs -- it's possible to returnCOMMENT