chore(release): bumped version to 2.0.0-beta.2
This commit is contained in:
Chen Sun
parent
931a68096e
commit
270257512a
78
CHANGELOG.md
78
CHANGELOG.md
|
|
@ -1,5 +1,83 @@
|
|||
# Changelog
|
||||
|
||||
## [2.0.0-beta.2](https://github.com/kubeflow/pipelines/compare/2.0.0-beta.1...2.0.0-beta.2) (2023-05-08)
|
||||
|
||||
|
||||
### ⚠ BREAKING CHANGES
|
||||
|
||||
* **SDK:** SDK client v2beta1 API integration. Fixes [\#8706](https://github.com/kubeflow/pipelines/issues/8706) ([\#9112](https://github.com/kubeflow/pipelines/issues/9112))
|
||||
|
||||
### Features
|
||||
|
||||
* **backend:** Add nodeSelector support. Closes [\#8959](https://github.com/kubeflow/pipelines/issues/8959). ([\#9132](https://github.com/kubeflow/pipelines/issues/9132)) ([276f922](https://github.com/kubeflow/pipelines/commit/276f922a68f483f10bf6ad7515e7c264ad0c0f1a))
|
||||
* **backend:** add parameter verification before submitting the workflow ([\#9228](https://github.com/kubeflow/pipelines/issues/9228)) ([52c4c6f](https://github.com/kubeflow/pipelines/commit/52c4c6f70d5d7107582a30dcebffc085426521cc))
|
||||
* **backend:** avoid downcast and use ExecutionSpec if possible ([\#9232](https://github.com/kubeflow/pipelines/issues/9232)) ([6c72d95](https://github.com/kubeflow/pipelines/commit/6c72d95b3fc1fb8edbc632a4d9201acd5db36117))
|
||||
* **backend:** support secrets ([\#9178](https://github.com/kubeflow/pipelines/issues/9178)) ([b8caf81](https://github.com/kubeflow/pipelines/commit/b8caf811c297ba5409c1ff607e3a04560a51a20a))
|
||||
* **components:** Add a remote runner for pipelines ([274ac8b](https://github.com/kubeflow/pipelines/commit/274ac8ba8b64660b52383b16b613b5535053b5b0))
|
||||
* **components:** Add logic in import_model_evaluation to accept explanations from slices ([4397b8c](https://github.com/kubeflow/pipelines/commit/4397b8c53f9d002ce2500f46b28d7ef5c6f9d349))
|
||||
* **components:** Add slicing_specs input to classification evaluation ([6a55449](https://github.com/kubeflow/pipelines/commit/6a55449ffb5b3d935b32033dc9a13b1852c059a4))
|
||||
* **components:** Allow batch predict component to add missing bq:// schemes ([8cc0550](https://github.com/kubeflow/pipelines/commit/8cc0550bac2b7e4135523a34e71ace9a2689d61e))
|
||||
* **components:** Allow importing LLM eval metrics ([ecc4ae0](https://github.com/kubeflow/pipelines/commit/ecc4ae02f103d5afb1381d03ef4498fe2a3a2e7b))
|
||||
* **components:** Change ResolveVertexModelOp name to GetVertexModelOp ([6a916e8](https://github.com/kubeflow/pipelines/commit/6a916e8b881404b8498aba074ff864cebd17cc79))
|
||||
* **components:** Create ResolveVertexModelOp component ([595ae8e](https://github.com/kubeflow/pipelines/commit/595ae8e9fd8e936e6d7e975de27e2a7bf7e3bce1))
|
||||
* **components:** Import user slices to the model evaluation importer ([8c9b716](https://github.com/kubeflow/pipelines/commit/8c9b7160b8ca2229e39e735af276782d7baa8863))
|
||||
* **components:** Sagemaker V2 Hosting components and tests ([\#9243](https://github.com/kubeflow/pipelines/issues/9243)) ([4818e84](https://github.com/kubeflow/pipelines/commit/4818e849f8e0cf7ddbb4c008fc43ec6f367d48cb))
|
||||
* **components:** Support model garden models in GetVertexModelOp ([0b32899](https://github.com/kubeflow/pipelines/commit/0b32899a7adf39dd88b54cc64e3ee651d24da7f3))
|
||||
* **components:** Update GCPC image version in two Eval importer components ([1f4d943](https://github.com/kubeflow/pipelines/commit/1f4d9437de69579dc8ef57389945b7fdf2a0f763))
|
||||
* **sdk:** support extracting input/output descriptions from component/pipeline docstrings ([\#9156](https://github.com/kubeflow/pipelines/issues/9156)) ([946c51b](https://github.com/kubeflow/pipelines/commit/946c51bafe955dd2dfa3e857e72bbf90ed5ed8ec))
|
||||
* **sdk:** Support submitting pipeline with platform config. ([\#9140](https://github.com/kubeflow/pipelines/issues/9140)) ([952e073](https://github.com/kubeflow/pipelines/commit/952e0730a80f0596ca628717d048b82438eaf287))
|
||||
* **SDK:** SDK client v2beta1 API integration. Fixes [\#8706](https://github.com/kubeflow/pipelines/issues/8706) ([\#9112](https://github.com/kubeflow/pipelines/issues/9112)) ([07d6c18](https://github.com/kubeflow/pipelines/commit/07d6c1816bf7cf06ae06b02c4c5d05e6261cf232))
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **api:** Regenerate v2beta1 API ([\#9197](https://github.com/kubeflow/pipelines/issues/9197)) ([7b70cb5](https://github.com/kubeflow/pipelines/commit/7b70cb5e3786da78d2022fc5eb802b896dc0f416))
|
||||
* **backend:** Add upsert for SQLite and MySQL dialects ([\#9245](https://github.com/kubeflow/pipelines/issues/9245)) ([2b92f9b](https://github.com/kubeflow/pipelines/commit/2b92f9bb61ee23107e7bed9b2fb6845e88352540))
|
||||
* **backend:** Allow empty namespace and remove default namespace. Fixes [\#8945](https://github.com/kubeflow/pipelines/issues/8945). Fixes [\#8897](https://github.com/kubeflow/pipelines/issues/8897). Fixes [\#8854](https://github.com/kubeflow/pipelines/issues/8854). ([\#9286](https://github.com/kubeflow/pipelines/issues/9286)) ([fbb8b39](https://github.com/kubeflow/pipelines/commit/fbb8b399b32e49f0683d2adf85d89dcbc30e3a31))
|
||||
* **backend:** Cleanup pipeline creation and upload logic ([\#9189](https://github.com/kubeflow/pipelines/issues/9189)) ([f5514c7](https://github.com/kubeflow/pipelines/commit/f5514c76624ab0614b0346d9f8205e443c525cd7))
|
||||
* **backend:** fix launcher importer error ([\#9290](https://github.com/kubeflow/pipelines/issues/9290)) ([38bf368](https://github.com/kubeflow/pipelines/commit/38bf3681d5d585eeababb25f59c4f38f73b760ec))
|
||||
* **backend:** Fix timestamp in task store, add disabled unit test ([\#9246](https://github.com/kubeflow/pipelines/issues/9246)) ([a975e99](https://github.com/kubeflow/pipelines/commit/a975e99d2a31c9cbb587f4114b4d14296d0557f2))
|
||||
* **backend:** fix volume bug ([\#9150](https://github.com/kubeflow/pipelines/issues/9150)) ([ca63f20](https://github.com/kubeflow/pipelines/commit/ca63f20049be092a3deeb1d44686e0b8860d4d02))
|
||||
* **components:** Changing path for model ([\#9331](https://github.com/kubeflow/pipelines/issues/9331)) ([aae9cb7](https://github.com/kubeflow/pipelines/commit/aae9cb74cb6a8a626388952c9847d49d810de5fa))
|
||||
* **components:** Evaluation metrics don't show when using TabNet on Tabular Workflows ([065d31c](https://github.com/kubeflow/pipelines/commit/065d31c7e2743e3e9b347883f1ace34a03c971c8))
|
||||
* **components:** fix BQML encryption_spec_key_name default value bug in experimental components ([12398e8](https://github.com/kubeflow/pipelines/commit/12398e86fa72aff6026f006516bca881cf7f7623))
|
||||
* **components:** Fix dataset preprocessor to get imported from v1 and change the default value for *_dataset_resource_name from None to empty string ([6677a95](https://github.com/kubeflow/pipelines/commit/6677a95974f64aaef4aeafc73276d9e7d5f27bd5))
|
||||
* **components:** Fix feature extractor component definition to make vertex dataset argument optional ([cc4a103](https://github.com/kubeflow/pipelines/commit/cc4a1037f0713b4e23986a1571a6f22c55805840))
|
||||
* **components:** fix type error for dict ([9d2abff](https://github.com/kubeflow/pipelines/commit/9d2abff8bcb55bf16e84a11650a28c5db3b2fe95))
|
||||
* **components:** fix VertexPromptValidationOp definition ([2abddf0](https://github.com/kubeflow/pipelines/commit/2abddf0db70d53d48b71286eacbc824c729c690f))
|
||||
* **components:** replace special characters (curved double quotes “”) in component YAML files ([f5b265e](https://github.com/kubeflow/pipelines/commit/f5b265e90adc114ffb2f5d524614c7aeb4e74b8f))
|
||||
* **components:** set input arg default values for import model evaluation ([52f6c97](https://github.com/kubeflow/pipelines/commit/52f6c978f5ceab083962337baa4c00e8eafcc07c))
|
||||
* **components:** Update Vertex Pipelines prompt validation component with new input parameters ([6fd7131](https://github.com/kubeflow/pipelines/commit/6fd71313f6978a46246dda257b1a1914ed8da43f))
|
||||
* **conformance:** enable healthz test in full Kubeflow. ([\#9297](https://github.com/kubeflow/pipelines/issues/9297)) ([2cfc428](https://github.com/kubeflow/pipelines/commit/2cfc4283d2aa81ae290a8cdda6f711e86e2cb5f7))
|
||||
* **frontend:** Buttons dislocated in narrow toolbar ([\#9344](https://github.com/kubeflow/pipelines/issues/9344)) ([1f8fdbc](https://github.com/kubeflow/pipelines/commit/1f8fdbcaef3e0343c0fb79a0d620ce0de399b731))
|
||||
* **frontend:** Change the incorrect loading context for run details ([\#9179](https://github.com/kubeflow/pipelines/issues/9179)) ([bb50b8d](https://github.com/kubeflow/pipelines/commit/bb50b8d729102dfed96d7118469647498a6b9bcb))
|
||||
* **frontend:** fail to clone SDK-created run / recurring run ([\#9255](https://github.com/kubeflow/pipelines/issues/9255)) ([47735f7](https://github.com/kubeflow/pipelines/commit/47735f74a8141ef94886f72cd482476986fe8741))
|
||||
* **frontend:** Failed pipeline version creation should not generate an empty pipeline. ([\#9342](https://github.com/kubeflow/pipelines/issues/9342)) ([9cfa3a2](https://github.com/kubeflow/pipelines/commit/9cfa3a27b83939390dbaf174d98b52edd1d579db))
|
||||
* **frontend:** Incorrect run type after pipeline is selected ([\#9339](https://github.com/kubeflow/pipelines/issues/9339)) ([5ff829a](https://github.com/kubeflow/pipelines/commit/5ff829ab6391f493202ada2a55c62c68e3be8605))
|
||||
* **frontend:** Logs details is not changed when selected other execution node. ([\#9334](https://github.com/kubeflow/pipelines/issues/9334)) ([f68e780](https://github.com/kubeflow/pipelines/commit/f68e7802e829a471171f039705f08ad2f540cc49))
|
||||
* **frontend:** Missing pipeline info while cloning recurring run. ([\#9231](https://github.com/kubeflow/pipelines/issues/9231)) ([c8f6031](https://github.com/kubeflow/pipelines/commit/c8f60315e804995b631ec956f8ca22958fdddeb5))
|
||||
* **frontend:** Parameter field is missing after choosing another v2 pipeline ([\#9202](https://github.com/kubeflow/pipelines/issues/9202)) ([1d659d1](https://github.com/kubeflow/pipelines/commit/1d659d15f49ec84f9ce66b622ccb4a97b2c08be4))
|
||||
* **frontend:** Parameter field is missing when creating run from run list ([\#9335](https://github.com/kubeflow/pipelines/issues/9335)) ([59db283](https://github.com/kubeflow/pipelines/commit/59db2835fa6ae2e9b8f11d2c3b4ccec4dc5c74b2))
|
||||
* **frontend:** Redirect to recurring run list after creating v1 recurring run. ([\#9280](https://github.com/kubeflow/pipelines/issues/9280)) ([34c7475](https://github.com/kubeflow/pipelines/commit/34c7475e3a6475b44f57577aaa11fc335feaebd3))
|
||||
* **frontend:** Render graph for yaml file containing platform_spec ([\#9192](https://github.com/kubeflow/pipelines/issues/9192)) ([d8672e6](https://github.com/kubeflow/pipelines/commit/d8672e6eacafebf4d84f0f6ced1cc6b297bc218f))
|
||||
* **frontend:** Render run parameters in run details tab. ([\#9217](https://github.com/kubeflow/pipelines/issues/9217)) ([d8f9885](https://github.com/kubeflow/pipelines/commit/d8f988529118351c4d0cd4424413def7ea07986b))
|
||||
* **frontend:** Replace obsoleted hyperlinks in new pipeline page. ([\#9181](https://github.com/kubeflow/pipelines/issues/9181)) ([3537504](https://github.com/kubeflow/pipelines/commit/353750465eb94b15e088299286c30aebdaa8e4e2))
|
||||
* **release:** Update release image with the latest api-generator ([\#9198](https://github.com/kubeflow/pipelines/issues/9198)) ([8645cac](https://github.com/kubeflow/pipelines/commit/8645cac9a6aa44cfe22cce71933b18614f23efac))
|
||||
* **sdk:** allow user to choose platform for component container build. Fixes [\#8883](https://github.com/kubeflow/pipelines/issues/8883) ([\#9212](https://github.com/kubeflow/pipelines/issues/9212)) ([b59b708](https://github.com/kubeflow/pipelines/commit/b59b70875ecdb5d5aef3b119b592c7733652ece7))
|
||||
* **sdk:** fix appengine import error ([\#9323](https://github.com/kubeflow/pipelines/issues/9323)) ([c437004](https://github.com/kubeflow/pipelines/commit/c437004761b282c4542e0cf627ac8cfef0741128))
|
||||
* **sdk:** fix handling of PipelineTaskFinalStatus in ir_type_ attribute hack ([\#9186](https://github.com/kubeflow/pipelines/issues/9186)) ([41c0d78](https://github.com/kubeflow/pipelines/commit/41c0d78f5f028c7906e1c2eb507fb2510a0fcff6))
|
||||
* **sdk:** fixes module not found error for containerized python components. Fixes [\#8385](https://github.com/kubeflow/pipelines/issues/8385) ([\#9157](https://github.com/kubeflow/pipelines/issues/9157)) ([3164dfb](https://github.com/kubeflow/pipelines/commit/3164dfb01ade53daaed838feba9f43f8fe108ee6))
|
||||
* **SDK:** fix `client.run_pipeline` with `pipeline_id` and `version_id` gives error ([\#9191](https://github.com/kubeflow/pipelines/issues/9191)) ([91277b1](https://github.com/kubeflow/pipelines/commit/91277b1e91cf999ed3e9d66514cd17e0abf4025a))
|
||||
|
||||
|
||||
### Other Pull Requests
|
||||
|
||||
* release 2.0.0b16 ([\#9325](https://github.com/kubeflow/pipelines/issues/9325)) ([58ebd20](https://github.com/kubeflow/pipelines/commit/58ebd202c4541d161f239aaa43321fa25f4c36b5))
|
||||
* [WIP] test: Add v2 upgrade test ([\#9287](https://github.com/kubeflow/pipelines/issues/9287)) ([e115e0c](https://github.com/kubeflow/pipelines/commit/e115e0c01f7a56aa0fb00ca9d31437a2c9ea80d8))
|
||||
* feat(components):Release the default pipeline with SLM feature selection ([4ccb0ef](https://github.com/kubeflow/pipelines/commit/4ccb0ef602ae24f42b498b55288bc9c4b6340204))
|
||||
* feature(frontend) Support Logs tab in KFP v2 ([\#9265](https://github.com/kubeflow/pipelines/issues/9265)) ([430bd54](https://github.com/kubeflow/pipelines/commit/430bd5406f1b8310158cd053929bb272dd577d5c))
|
||||
* feat(sdk): support `display_name` and `description` in `@dsl.pipeline` decorator ([\#9153](https://github.com/kubeflow/pipelines/issues/9153)) ([91abbea](https://github.com/kubeflow/pipelines/commit/91abbeaf2fda4aebc6f5bffbb2a701a3728cb2f2))
|
||||
|
||||
## [2.0.0-beta.1](https://github.com/kubeflow/pipelines/compare/2.0.0-beta.0...2.0.0-beta.1) (2023-04-11)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -36,7 +36,10 @@ func request_AuthService_AuthorizeV1_0(ctx context.Context, marshaler runtime.Ma
|
|||
var protoReq AuthorizeRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_AuthService_AuthorizeV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_AuthService_AuthorizeV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -107,7 +110,7 @@ func RegisterAuthServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_AuthService_AuthorizeV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "auth"}, ""))
|
||||
pattern_AuthService_AuthorizeV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "auth"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -80,7 +80,10 @@ func request_ExperimentService_ListExperimentsV1_0(ctx context.Context, marshale
|
|||
var protoReq ListExperimentsRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_ExperimentService_ListExperimentsV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_ExperimentService_ListExperimentsV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -332,17 +335,17 @@ func RegisterExperimentServiceHandlerClient(ctx context.Context, mux *runtime.Se
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_ExperimentService_CreateExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "experiments"}, ""))
|
||||
pattern_ExperimentService_CreateExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "experiments"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ExperimentService_GetExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, ""))
|
||||
pattern_ExperimentService_GetExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ExperimentService_ListExperimentsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "experiments"}, ""))
|
||||
pattern_ExperimentService_ListExperimentsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "experiments"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ExperimentService_DeleteExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, ""))
|
||||
pattern_ExperimentService_DeleteExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ExperimentService_ArchiveExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "archive"))
|
||||
pattern_ExperimentService_ArchiveExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "archive", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ExperimentService_UnarchiveExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "unarchive"))
|
||||
pattern_ExperimentService_UnarchiveExperimentV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "experiments", "id"}, "unarchive", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -100,7 +100,7 @@ func RegisterHealthzServiceHandlerClient(ctx context.Context, mux *runtime.Serve
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_HealthzService_GetHealthz_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "healthz"}, ""))
|
||||
pattern_HealthzService_GetHealthz_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "healthz"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -80,7 +80,10 @@ func request_JobService_ListJobs_0(ctx context.Context, marshaler runtime.Marsha
|
|||
var protoReq ListJobsRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_JobService_ListJobs_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_JobService_ListJobs_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -332,17 +335,17 @@ func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux,
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_JobService_CreateJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "jobs"}, ""))
|
||||
pattern_JobService_CreateJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "jobs"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_JobService_GetJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "jobs", "id"}, ""))
|
||||
pattern_JobService_GetJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "jobs", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_JobService_ListJobs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "jobs"}, ""))
|
||||
pattern_JobService_ListJobs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "jobs"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_JobService_EnableJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "jobs", "id", "enable"}, ""))
|
||||
pattern_JobService_EnableJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "jobs", "id", "enable"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_JobService_DisableJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "jobs", "id", "disable"}, ""))
|
||||
pattern_JobService_DisableJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "jobs", "id", "disable"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_JobService_DeleteJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "jobs", "id"}, ""))
|
||||
pattern_JobService_DeleteJob_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "jobs", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -118,7 +118,10 @@ func request_PipelineService_ListPipelinesV1_0(ctx context.Context, marshaler ru
|
|||
var protoReq ListPipelinesRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_PipelineService_ListPipelinesV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_PipelineService_ListPipelinesV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -233,7 +236,10 @@ func request_PipelineService_ListPipelineVersionsV1_0(ctx context.Context, marsh
|
|||
var protoReq ListPipelineVersionsRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_PipelineService_ListPipelineVersionsV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_PipelineService_ListPipelineVersionsV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -616,29 +622,29 @@ func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.Serv
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_PipelineService_CreatePipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipelines"}, ""))
|
||||
pattern_PipelineService_CreatePipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipelines"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_GetPipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipelines", "id"}, ""))
|
||||
pattern_PipelineService_GetPipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipelines", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_GetPipelineByNameV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"apis", "v1beta1", "namespaces", "namespace", "pipelines", "name"}, ""))
|
||||
pattern_PipelineService_GetPipelineByNameV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"apis", "v1beta1", "namespaces", "namespace", "pipelines", "name"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_ListPipelinesV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipelines"}, ""))
|
||||
pattern_PipelineService_ListPipelinesV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipelines"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_DeletePipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipelines", "id"}, ""))
|
||||
pattern_PipelineService_DeletePipelineV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipelines", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_GetTemplate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "pipelines", "id", "templates"}, ""))
|
||||
pattern_PipelineService_GetTemplate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "pipelines", "id", "templates"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_CreatePipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipeline_versions"}, ""))
|
||||
pattern_PipelineService_CreatePipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipeline_versions"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_GetPipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipeline_versions", "version_id"}, ""))
|
||||
pattern_PipelineService_GetPipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipeline_versions", "version_id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_ListPipelineVersionsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipeline_versions"}, ""))
|
||||
pattern_PipelineService_ListPipelineVersionsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "pipeline_versions"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_DeletePipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipeline_versions", "version_id"}, ""))
|
||||
pattern_PipelineService_DeletePipelineVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "pipeline_versions", "version_id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_GetPipelineVersionTemplate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "pipeline_versions", "version_id", "templates"}, ""))
|
||||
pattern_PipelineService_GetPipelineVersionTemplate_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "pipeline_versions", "version_id", "templates"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_PipelineService_UpdatePipelineDefaultVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"apis", "v1beta1", "pipelines", "pipeline_id", "default_version", "version_id"}, ""))
|
||||
pattern_PipelineService_UpdatePipelineDefaultVersionV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"apis", "v1beta1", "pipelines", "pipeline_id", "default_version", "version_id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -144,9 +144,9 @@ func RegisterReportServiceHandlerClient(ctx context.Context, mux *runtime.ServeM
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_ReportService_ReportWorkflowV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "workflows"}, ""))
|
||||
pattern_ReportService_ReportWorkflowV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "workflows"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_ReportService_ReportScheduledWorkflowV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "scheduledworkflows"}, ""))
|
||||
pattern_ReportService_ReportScheduledWorkflowV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "scheduledworkflows"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -80,7 +80,10 @@ func request_RunService_ListRunsV1_0(ctx context.Context, marshaler runtime.Mars
|
|||
var protoReq ListRunsRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_RunService_ListRunsV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_RunService_ListRunsV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -550,25 +553,25 @@ func RegisterRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux,
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_RunService_CreateRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "runs"}, ""))
|
||||
pattern_RunService_CreateRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "runs"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_GetRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "run_id"}, ""))
|
||||
pattern_RunService_GetRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "run_id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_ListRunsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "runs"}, ""))
|
||||
pattern_RunService_ListRunsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1beta1", "runs"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_ArchiveRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, "archive"))
|
||||
pattern_RunService_ArchiveRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, "archive", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_UnarchiveRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, "unarchive"))
|
||||
pattern_RunService_UnarchiveRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, "unarchive", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_DeleteRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, ""))
|
||||
pattern_RunService_DeleteRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "id"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_ReportRunMetricsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "run_id"}, "reportMetrics"))
|
||||
pattern_RunService_ReportRunMetricsV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "runs", "run_id"}, "reportMetrics", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_ReadArtifactV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5, 2, 6, 1, 0, 4, 1, 5, 7}, []string{"apis", "v1beta1", "runs", "run_id", "nodes", "node_id", "artifacts", "artifact_name"}, "read"))
|
||||
pattern_RunService_ReadArtifactV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5, 2, 6, 1, 0, 4, 1, 5, 7}, []string{"apis", "v1beta1", "runs", "run_id", "nodes", "node_id", "artifacts", "artifact_name"}, "read", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_TerminateRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "runs", "run_id", "terminate"}, ""))
|
||||
pattern_RunService_TerminateRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "runs", "run_id", "terminate"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_RunService_RetryRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "runs", "run_id", "retry"}, ""))
|
||||
pattern_RunService_RetryRunV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"apis", "v1beta1", "runs", "run_id", "retry"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -53,7 +53,10 @@ func request_TaskService_ListTasksV1_0(ctx context.Context, marshaler runtime.Ma
|
|||
var protoReq ListTasksRequest
|
||||
var metadata runtime.ServerMetadata
|
||||
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_TaskService_ListTasksV1_0); err != nil {
|
||||
if err := req.ParseForm(); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_TaskService_ListTasksV1_0); err != nil {
|
||||
return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
|
||||
}
|
||||
|
||||
|
|
@ -144,9 +147,9 @@ func RegisterTaskServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_TaskService_CreateTaskV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1alpha1", "tasks"}, ""))
|
||||
pattern_TaskService_CreateTaskV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1alpha1", "tasks"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
|
||||
pattern_TaskService_ListTasksV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1alpha1", "tasks"}, ""))
|
||||
pattern_TaskService_ListTasksV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "v1alpha1", "tasks"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -125,7 +125,7 @@ func RegisterVisualizationServiceHandlerClient(ctx context.Context, mux *runtime
|
|||
}
|
||||
|
||||
var (
|
||||
pattern_VisualizationService_CreateVisualizationV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "visualizations", "namespace"}, ""))
|
||||
pattern_VisualizationService_CreateVisualizationV1_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3}, []string{"apis", "v1beta1", "visualizations", "namespace"}, "", runtime.AssumeColonVerbOpt(true)))
|
||||
)
|
||||
|
||||
var (
|
||||
|
|
|
|||
|
|
@ -8,9 +8,7 @@ package job_model
|
|||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
"github.com/go-openapi/validate"
|
||||
)
|
||||
|
||||
// PipelineSpecRuntimeConfig The runtime config of a PipelineSpec.
|
||||
|
|
@ -20,7 +18,7 @@ type PipelineSpecRuntimeConfig struct {
|
|||
// The runtime parameters of the PipelineSpec. The parameters will be
|
||||
// used to replace the placeholders
|
||||
// at runtime.
|
||||
Parameters map[string]ProtobufValue `json:"parameters,omitempty"`
|
||||
Parameters map[string]interface{} `json:"parameters,omitempty"`
|
||||
|
||||
// A path in a object store bucket which will be treated as the root
|
||||
// output directory of the pipeline. It is used by the system to
|
||||
|
|
@ -30,37 +28,6 @@ type PipelineSpecRuntimeConfig struct {
|
|||
|
||||
// Validate validates this pipeline spec runtime config
|
||||
func (m *PipelineSpecRuntimeConfig) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateParameters(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *PipelineSpecRuntimeConfig) validateParameters(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Parameters) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for k := range m.Parameters {
|
||||
|
||||
if err := validate.Required("parameters"+"."+k, "body", m.Parameters[k]); err != nil {
|
||||
return err
|
||||
}
|
||||
if val, ok := m.Parameters[k]; ok {
|
||||
if err := val.Validate(formats); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -1,82 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package job_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
"strconv"
|
||||
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
)
|
||||
|
||||
// ProtobufListValue `ListValue` is a wrapper around a repeated field of values.
|
||||
//
|
||||
// The JSON representation for `ListValue` is JSON array.
|
||||
// swagger:model protobufListValue
|
||||
type ProtobufListValue struct {
|
||||
|
||||
// Repeated field of dynamically typed values.
|
||||
Values []*ProtobufValue `json:"values"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf list value
|
||||
func (m *ProtobufListValue) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateValues(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufListValue) validateValues(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Values) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for i := 0; i < len(m.Values); i++ {
|
||||
if swag.IsZero(m.Values[i]) { // not required
|
||||
continue
|
||||
}
|
||||
|
||||
if m.Values[i] != nil {
|
||||
if err := m.Values[i].Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("values" + "." + strconv.Itoa(i))
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufListValue) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufListValue) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufListValue
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package job_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
"github.com/go-openapi/validate"
|
||||
)
|
||||
|
||||
// ProtobufStruct `Struct` represents a structured data value, consisting of fields
|
||||
// which map to dynamically typed values. In some languages, `Struct`
|
||||
// might be supported by a native representation. For example, in
|
||||
// scripting languages like JS a struct is represented as an
|
||||
// object. The details of that representation are described together
|
||||
// with the proto support for the language.
|
||||
//
|
||||
// The JSON representation for `Struct` is JSON object.
|
||||
// swagger:model protobufStruct
|
||||
type ProtobufStruct struct {
|
||||
|
||||
// Unordered map of dynamically typed values.
|
||||
Fields map[string]ProtobufValue `json:"fields,omitempty"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf struct
|
||||
func (m *ProtobufStruct) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateFields(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufStruct) validateFields(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Fields) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for k := range m.Fields {
|
||||
|
||||
if err := validate.Required("fields"+"."+k, "body", m.Fields[k]); err != nil {
|
||||
return err
|
||||
}
|
||||
if val, ok := m.Fields[k]; ok {
|
||||
if err := val.Validate(formats); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufStruct) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufStruct) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufStruct
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1,133 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package job_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
)
|
||||
|
||||
// ProtobufValue `Value` represents a dynamically typed value which can be either
|
||||
// null, a number, a string, a boolean, a recursive struct value, or a
|
||||
// list of values. A producer of value is expected to set one of that
|
||||
// variants, absence of any variant indicates an error.
|
||||
//
|
||||
// The JSON representation for `Value` is JSON value.
|
||||
// swagger:model protobufValue
|
||||
type ProtobufValue struct {
|
||||
|
||||
// Represents a boolean value.
|
||||
BoolValue bool `json:"bool_value,omitempty"`
|
||||
|
||||
// Represents a repeated `Value`.
|
||||
ListValue *ProtobufListValue `json:"list_value,omitempty"`
|
||||
|
||||
// Represents a null value.
|
||||
NullValue ProtobufNullValue `json:"null_value,omitempty"`
|
||||
|
||||
// Represents a double value.
|
||||
NumberValue float64 `json:"number_value,omitempty"`
|
||||
|
||||
// Represents a string value.
|
||||
StringValue string `json:"string_value,omitempty"`
|
||||
|
||||
// Represents a structured value.
|
||||
StructValue *ProtobufStruct `json:"struct_value,omitempty"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf value
|
||||
func (m *ProtobufValue) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateListValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if err := m.validateNullValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if err := m.validateStructValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateListValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.ListValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if m.ListValue != nil {
|
||||
if err := m.ListValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("list_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateNullValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.NullValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if err := m.NullValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("null_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateStructValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.StructValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if m.StructValue != nil {
|
||||
if err := m.StructValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("struct_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufValue) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufValue) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufValue
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -8,9 +8,7 @@ package run_model
|
|||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
"github.com/go-openapi/validate"
|
||||
)
|
||||
|
||||
// PipelineSpecRuntimeConfig The runtime config of a PipelineSpec.
|
||||
|
|
@ -20,7 +18,7 @@ type PipelineSpecRuntimeConfig struct {
|
|||
// The runtime parameters of the PipelineSpec. The parameters will be
|
||||
// used to replace the placeholders
|
||||
// at runtime.
|
||||
Parameters map[string]ProtobufValue `json:"parameters,omitempty"`
|
||||
Parameters map[string]interface{} `json:"parameters,omitempty"`
|
||||
|
||||
// A path in a object store bucket which will be treated as the root
|
||||
// output directory of the pipeline. It is used by the system to
|
||||
|
|
@ -30,37 +28,6 @@ type PipelineSpecRuntimeConfig struct {
|
|||
|
||||
// Validate validates this pipeline spec runtime config
|
||||
func (m *PipelineSpecRuntimeConfig) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateParameters(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *PipelineSpecRuntimeConfig) validateParameters(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Parameters) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for k := range m.Parameters {
|
||||
|
||||
if err := validate.Required("parameters"+"."+k, "body", m.Parameters[k]); err != nil {
|
||||
return err
|
||||
}
|
||||
if val, ok := m.Parameters[k]; ok {
|
||||
if err := val.Validate(formats); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -1,82 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package run_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
"strconv"
|
||||
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
)
|
||||
|
||||
// ProtobufListValue `ListValue` is a wrapper around a repeated field of values.
|
||||
//
|
||||
// The JSON representation for `ListValue` is JSON array.
|
||||
// swagger:model protobufListValue
|
||||
type ProtobufListValue struct {
|
||||
|
||||
// Repeated field of dynamically typed values.
|
||||
Values []*ProtobufValue `json:"values"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf list value
|
||||
func (m *ProtobufListValue) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateValues(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufListValue) validateValues(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Values) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for i := 0; i < len(m.Values); i++ {
|
||||
if swag.IsZero(m.Values[i]) { // not required
|
||||
continue
|
||||
}
|
||||
|
||||
if m.Values[i] != nil {
|
||||
if err := m.Values[i].Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("values" + "." + strconv.Itoa(i))
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufListValue) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufListValue) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufListValue
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1,83 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package run_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
"github.com/go-openapi/validate"
|
||||
)
|
||||
|
||||
// ProtobufStruct `Struct` represents a structured data value, consisting of fields
|
||||
// which map to dynamically typed values. In some languages, `Struct`
|
||||
// might be supported by a native representation. For example, in
|
||||
// scripting languages like JS a struct is represented as an
|
||||
// object. The details of that representation are described together
|
||||
// with the proto support for the language.
|
||||
//
|
||||
// The JSON representation for `Struct` is JSON object.
|
||||
// swagger:model protobufStruct
|
||||
type ProtobufStruct struct {
|
||||
|
||||
// Unordered map of dynamically typed values.
|
||||
Fields map[string]ProtobufValue `json:"fields,omitempty"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf struct
|
||||
func (m *ProtobufStruct) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateFields(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufStruct) validateFields(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.Fields) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
for k := range m.Fields {
|
||||
|
||||
if err := validate.Required("fields"+"."+k, "body", m.Fields[k]); err != nil {
|
||||
return err
|
||||
}
|
||||
if val, ok := m.Fields[k]; ok {
|
||||
if err := val.Validate(formats); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufStruct) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufStruct) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufStruct
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1,133 +0,0 @@
|
|||
// Code generated by go-swagger; DO NOT EDIT.
|
||||
|
||||
package run_model
|
||||
|
||||
// This file was generated by the swagger tool.
|
||||
// Editing this file might prove futile when you re-run the swagger generate command
|
||||
|
||||
import (
|
||||
strfmt "github.com/go-openapi/strfmt"
|
||||
|
||||
"github.com/go-openapi/errors"
|
||||
"github.com/go-openapi/swag"
|
||||
)
|
||||
|
||||
// ProtobufValue `Value` represents a dynamically typed value which can be either
|
||||
// null, a number, a string, a boolean, a recursive struct value, or a
|
||||
// list of values. A producer of value is expected to set one of that
|
||||
// variants, absence of any variant indicates an error.
|
||||
//
|
||||
// The JSON representation for `Value` is JSON value.
|
||||
// swagger:model protobufValue
|
||||
type ProtobufValue struct {
|
||||
|
||||
// Represents a boolean value.
|
||||
BoolValue bool `json:"bool_value,omitempty"`
|
||||
|
||||
// Represents a repeated `Value`.
|
||||
ListValue *ProtobufListValue `json:"list_value,omitempty"`
|
||||
|
||||
// Represents a null value.
|
||||
NullValue ProtobufNullValue `json:"null_value,omitempty"`
|
||||
|
||||
// Represents a double value.
|
||||
NumberValue float64 `json:"number_value,omitempty"`
|
||||
|
||||
// Represents a string value.
|
||||
StringValue string `json:"string_value,omitempty"`
|
||||
|
||||
// Represents a structured value.
|
||||
StructValue *ProtobufStruct `json:"struct_value,omitempty"`
|
||||
}
|
||||
|
||||
// Validate validates this protobuf value
|
||||
func (m *ProtobufValue) Validate(formats strfmt.Registry) error {
|
||||
var res []error
|
||||
|
||||
if err := m.validateListValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if err := m.validateNullValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if err := m.validateStructValue(formats); err != nil {
|
||||
res = append(res, err)
|
||||
}
|
||||
|
||||
if len(res) > 0 {
|
||||
return errors.CompositeValidationError(res...)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateListValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.ListValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if m.ListValue != nil {
|
||||
if err := m.ListValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("list_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateNullValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.NullValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if err := m.NullValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("null_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProtobufValue) validateStructValue(formats strfmt.Registry) error {
|
||||
|
||||
if swag.IsZero(m.StructValue) { // not required
|
||||
return nil
|
||||
}
|
||||
|
||||
if m.StructValue != nil {
|
||||
if err := m.StructValue.Validate(formats); err != nil {
|
||||
if ve, ok := err.(*errors.Validation); ok {
|
||||
return ve.ValidateName("struct_value")
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalBinary interface implementation
|
||||
func (m *ProtobufValue) MarshalBinary() ([]byte, error) {
|
||||
if m == nil {
|
||||
return nil, nil
|
||||
}
|
||||
return swag.WriteJSON(m)
|
||||
}
|
||||
|
||||
// UnmarshalBinary interface implementation
|
||||
func (m *ProtobufValue) UnmarshalBinary(b []byte) error {
|
||||
var res ProtobufValue
|
||||
if err := swag.ReadJSON(b, &res); err != nil {
|
||||
return err
|
||||
}
|
||||
*m = res
|
||||
return nil
|
||||
}
|
||||
|
|
@ -3,8 +3,8 @@ This file contains REST API specification for Kubeflow Pipelines. The file is au
|
|||
|
||||
This Python package is automatically generated by the [OpenAPI Generator](https://openapi-generator.tech) project:
|
||||
|
||||
- API version: 2.0.0-beta.1
|
||||
- Package version: 2.0.0-beta.1
|
||||
- API version: 2.0.0-beta.2
|
||||
- Package version: 2.0.0-beta.2
|
||||
- Build package: org.openapitools.codegen.languages.PythonClientCodegen
|
||||
For more information, please visit [https://www.google.com](https://www.google.com)
|
||||
|
||||
|
|
@ -171,10 +171,7 @@ Class | Method | HTTP request | Description
|
|||
- [JobMode](docs/JobMode.md)
|
||||
- [PipelineSpecRuntimeConfig](docs/PipelineSpecRuntimeConfig.md)
|
||||
- [ProtobufAny](docs/ProtobufAny.md)
|
||||
- [ProtobufListValue](docs/ProtobufListValue.md)
|
||||
- [ProtobufNullValue](docs/ProtobufNullValue.md)
|
||||
- [ProtobufStruct](docs/ProtobufStruct.md)
|
||||
- [ProtobufValue](docs/ProtobufValue.md)
|
||||
- [ReportRunMetricsResponseReportRunMetricResult](docs/ReportRunMetricsResponseReportRunMetricResult.md)
|
||||
- [ReportRunMetricsResponseReportRunMetricResultStatus](docs/ReportRunMetricsResponseReportRunMetricResultStatus.md)
|
||||
- [RunMetricFormat](docs/RunMetricFormat.md)
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@ The runtime config of a PipelineSpec.
|
|||
## Properties
|
||||
Name | Type | Description | Notes
|
||||
------------ | ------------- | ------------- | -------------
|
||||
**parameters** | [**dict(str, ProtobufValue)**](ProtobufValue.md) | The runtime parameters of the PipelineSpec. The parameters will be used to replace the placeholders at runtime. | [optional]
|
||||
**parameters** | **dict(str, object)** | The runtime parameters of the PipelineSpec. The parameters will be used to replace the placeholders at runtime. | [optional]
|
||||
**pipeline_root** | **str** | | [optional]
|
||||
|
||||
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
|
||||
|
|
|
|||
|
|
@ -1,11 +0,0 @@
|
|||
# ProtobufListValue
|
||||
|
||||
`ListValue` is a wrapper around a repeated field of values. The JSON representation for `ListValue` is JSON array.
|
||||
## Properties
|
||||
Name | Type | Description | Notes
|
||||
------------ | ------------- | ------------- | -------------
|
||||
**values** | [**list[ProtobufValue]**](ProtobufValue.md) | Repeated field of dynamically typed values. | [optional]
|
||||
|
||||
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
|
||||
|
||||
|
||||
|
|
@ -1,11 +0,0 @@
|
|||
# ProtobufStruct
|
||||
|
||||
`Struct` represents a structured data value, consisting of fields which map to dynamically typed values. In some languages, `Struct` might be supported by a native representation. For example, in scripting languages like JS a struct is represented as an object. The details of that representation are described together with the proto support for the language. The JSON representation for `Struct` is JSON object.
|
||||
## Properties
|
||||
Name | Type | Description | Notes
|
||||
------------ | ------------- | ------------- | -------------
|
||||
**fields** | [**dict(str, ProtobufValue)**](ProtobufValue.md) | Unordered map of dynamically typed values. | [optional]
|
||||
|
||||
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
|
||||
|
||||
|
||||
|
|
@ -1,16 +0,0 @@
|
|||
# ProtobufValue
|
||||
|
||||
`Value` represents a dynamically typed value which can be either null, a number, a string, a boolean, a recursive struct value, or a list of values. A producer of value is expected to set one of that variants, absence of any variant indicates an error. The JSON representation for `Value` is JSON value.
|
||||
## Properties
|
||||
Name | Type | Description | Notes
|
||||
------------ | ------------- | ------------- | -------------
|
||||
**null_value** | [**ProtobufNullValue**](ProtobufNullValue.md) | | [optional]
|
||||
**number_value** | **float** | Represents a double value. | [optional]
|
||||
**string_value** | **str** | Represents a string value. | [optional]
|
||||
**bool_value** | **bool** | Represents a boolean value. | [optional]
|
||||
**struct_value** | [**ProtobufStruct**](ProtobufStruct.md) | | [optional]
|
||||
**list_value** | [**ProtobufListValue**](ProtobufListValue.md) | | [optional]
|
||||
|
||||
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
|
||||
|
||||
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
|
||||
from __future__ import absolute_import
|
||||
|
||||
__version__ = "2.0.0-beta.1"
|
||||
__version__ = "2.0.0-beta.2"
|
||||
|
||||
# import apis into sdk package
|
||||
from kfp_server_api.api.experiment_service_api import ExperimentServiceApi
|
||||
|
|
@ -67,10 +67,7 @@ from kfp_server_api.models.api_url import ApiUrl
|
|||
from kfp_server_api.models.job_mode import JobMode
|
||||
from kfp_server_api.models.pipeline_spec_runtime_config import PipelineSpecRuntimeConfig
|
||||
from kfp_server_api.models.protobuf_any import ProtobufAny
|
||||
from kfp_server_api.models.protobuf_list_value import ProtobufListValue
|
||||
from kfp_server_api.models.protobuf_null_value import ProtobufNullValue
|
||||
from kfp_server_api.models.protobuf_struct import ProtobufStruct
|
||||
from kfp_server_api.models.protobuf_value import ProtobufValue
|
||||
from kfp_server_api.models.report_run_metrics_response_report_run_metric_result import ReportRunMetricsResponseReportRunMetricResult
|
||||
from kfp_server_api.models.report_run_metrics_response_report_run_metric_result_status import ReportRunMetricsResponseReportRunMetricResultStatus
|
||||
from kfp_server_api.models.run_metric_format import RunMetricFormat
|
||||
|
|
|
|||
|
|
@ -78,7 +78,7 @@ class ApiClient(object):
|
|||
self.default_headers[header_name] = header_value
|
||||
self.cookie = cookie
|
||||
# Set default User-Agent.
|
||||
self.user_agent = 'OpenAPI-Generator/2.0.0-beta.1/python'
|
||||
self.user_agent = 'OpenAPI-Generator/2.0.0-beta.2/python'
|
||||
self.client_side_validation = configuration.client_side_validation
|
||||
|
||||
def __enter__(self):
|
||||
|
|
|
|||
|
|
@ -351,8 +351,8 @@ conf = kfp_server_api.Configuration(
|
|||
return "Python SDK Debug Report:\n"\
|
||||
"OS: {env}\n"\
|
||||
"Python Version: {pyversion}\n"\
|
||||
"Version of the API: 2.0.0-beta.1\n"\
|
||||
"SDK Package Version: 2.0.0-beta.1".\
|
||||
"Version of the API: 2.0.0-beta.2\n"\
|
||||
"SDK Package Version: 2.0.0-beta.2".\
|
||||
format(env=sys.platform, pyversion=sys.version)
|
||||
|
||||
def get_host_settings(self):
|
||||
|
|
|
|||
|
|
@ -48,10 +48,7 @@ from kfp_server_api.models.api_url import ApiUrl
|
|||
from kfp_server_api.models.job_mode import JobMode
|
||||
from kfp_server_api.models.pipeline_spec_runtime_config import PipelineSpecRuntimeConfig
|
||||
from kfp_server_api.models.protobuf_any import ProtobufAny
|
||||
from kfp_server_api.models.protobuf_list_value import ProtobufListValue
|
||||
from kfp_server_api.models.protobuf_null_value import ProtobufNullValue
|
||||
from kfp_server_api.models.protobuf_struct import ProtobufStruct
|
||||
from kfp_server_api.models.protobuf_value import ProtobufValue
|
||||
from kfp_server_api.models.report_run_metrics_response_report_run_metric_result import ReportRunMetricsResponseReportRunMetricResult
|
||||
from kfp_server_api.models.report_run_metrics_response_report_run_metric_result_status import ReportRunMetricsResponseReportRunMetricResultStatus
|
||||
from kfp_server_api.models.run_metric_format import RunMetricFormat
|
||||
|
|
|
|||
|
|
@ -33,7 +33,7 @@ class PipelineSpecRuntimeConfig(object):
|
|||
and the value is json key in definition.
|
||||
"""
|
||||
openapi_types = {
|
||||
'parameters': 'dict(str, ProtobufValue)',
|
||||
'parameters': 'dict(str, object)',
|
||||
'pipeline_root': 'str'
|
||||
}
|
||||
|
||||
|
|
@ -64,7 +64,7 @@ class PipelineSpecRuntimeConfig(object):
|
|||
The runtime parameters of the PipelineSpec. The parameters will be used to replace the placeholders at runtime. # noqa: E501
|
||||
|
||||
:return: The parameters of this PipelineSpecRuntimeConfig. # noqa: E501
|
||||
:rtype: dict(str, ProtobufValue)
|
||||
:rtype: dict(str, object)
|
||||
"""
|
||||
return self._parameters
|
||||
|
||||
|
|
@ -75,7 +75,7 @@ class PipelineSpecRuntimeConfig(object):
|
|||
The runtime parameters of the PipelineSpec. The parameters will be used to replace the placeholders at runtime. # noqa: E501
|
||||
|
||||
:param parameters: The parameters of this PipelineSpecRuntimeConfig. # noqa: E501
|
||||
:type parameters: dict(str, ProtobufValue)
|
||||
:type parameters: dict(str, object)
|
||||
"""
|
||||
|
||||
self._parameters = parameters
|
||||
|
|
|
|||
|
|
@ -1,122 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
import pprint
|
||||
import re # noqa: F401
|
||||
|
||||
import six
|
||||
|
||||
from kfp_server_api.configuration import Configuration
|
||||
|
||||
|
||||
class ProtobufListValue(object):
|
||||
"""NOTE: This class is auto generated by OpenAPI Generator.
|
||||
Ref: https://openapi-generator.tech
|
||||
|
||||
Do not edit the class manually.
|
||||
"""
|
||||
|
||||
"""
|
||||
Attributes:
|
||||
openapi_types (dict): The key is attribute name
|
||||
and the value is attribute type.
|
||||
attribute_map (dict): The key is attribute name
|
||||
and the value is json key in definition.
|
||||
"""
|
||||
openapi_types = {
|
||||
'values': 'list[ProtobufValue]'
|
||||
}
|
||||
|
||||
attribute_map = {
|
||||
'values': 'values'
|
||||
}
|
||||
|
||||
def __init__(self, values=None, local_vars_configuration=None): # noqa: E501
|
||||
"""ProtobufListValue - a model defined in OpenAPI""" # noqa: E501
|
||||
if local_vars_configuration is None:
|
||||
local_vars_configuration = Configuration()
|
||||
self.local_vars_configuration = local_vars_configuration
|
||||
|
||||
self._values = None
|
||||
self.discriminator = None
|
||||
|
||||
if values is not None:
|
||||
self.values = values
|
||||
|
||||
@property
|
||||
def values(self):
|
||||
"""Gets the values of this ProtobufListValue. # noqa: E501
|
||||
|
||||
Repeated field of dynamically typed values. # noqa: E501
|
||||
|
||||
:return: The values of this ProtobufListValue. # noqa: E501
|
||||
:rtype: list[ProtobufValue]
|
||||
"""
|
||||
return self._values
|
||||
|
||||
@values.setter
|
||||
def values(self, values):
|
||||
"""Sets the values of this ProtobufListValue.
|
||||
|
||||
Repeated field of dynamically typed values. # noqa: E501
|
||||
|
||||
:param values: The values of this ProtobufListValue. # noqa: E501
|
||||
:type values: list[ProtobufValue]
|
||||
"""
|
||||
|
||||
self._values = values
|
||||
|
||||
def to_dict(self):
|
||||
"""Returns the model properties as a dict"""
|
||||
result = {}
|
||||
|
||||
for attr, _ in six.iteritems(self.openapi_types):
|
||||
value = getattr(self, attr)
|
||||
if isinstance(value, list):
|
||||
result[attr] = list(map(
|
||||
lambda x: x.to_dict() if hasattr(x, "to_dict") else x,
|
||||
value
|
||||
))
|
||||
elif hasattr(value, "to_dict"):
|
||||
result[attr] = value.to_dict()
|
||||
elif isinstance(value, dict):
|
||||
result[attr] = dict(map(
|
||||
lambda item: (item[0], item[1].to_dict())
|
||||
if hasattr(item[1], "to_dict") else item,
|
||||
value.items()
|
||||
))
|
||||
else:
|
||||
result[attr] = value
|
||||
|
||||
return result
|
||||
|
||||
def to_str(self):
|
||||
"""Returns the string representation of the model"""
|
||||
return pprint.pformat(self.to_dict())
|
||||
|
||||
def __repr__(self):
|
||||
"""For `print` and `pprint`"""
|
||||
return self.to_str()
|
||||
|
||||
def __eq__(self, other):
|
||||
"""Returns true if both objects are equal"""
|
||||
if not isinstance(other, ProtobufListValue):
|
||||
return False
|
||||
|
||||
return self.to_dict() == other.to_dict()
|
||||
|
||||
def __ne__(self, other):
|
||||
"""Returns true if both objects are not equal"""
|
||||
if not isinstance(other, ProtobufListValue):
|
||||
return True
|
||||
|
||||
return self.to_dict() != other.to_dict()
|
||||
|
|
@ -1,122 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
import pprint
|
||||
import re # noqa: F401
|
||||
|
||||
import six
|
||||
|
||||
from kfp_server_api.configuration import Configuration
|
||||
|
||||
|
||||
class ProtobufStruct(object):
|
||||
"""NOTE: This class is auto generated by OpenAPI Generator.
|
||||
Ref: https://openapi-generator.tech
|
||||
|
||||
Do not edit the class manually.
|
||||
"""
|
||||
|
||||
"""
|
||||
Attributes:
|
||||
openapi_types (dict): The key is attribute name
|
||||
and the value is attribute type.
|
||||
attribute_map (dict): The key is attribute name
|
||||
and the value is json key in definition.
|
||||
"""
|
||||
openapi_types = {
|
||||
'fields': 'dict(str, ProtobufValue)'
|
||||
}
|
||||
|
||||
attribute_map = {
|
||||
'fields': 'fields'
|
||||
}
|
||||
|
||||
def __init__(self, fields=None, local_vars_configuration=None): # noqa: E501
|
||||
"""ProtobufStruct - a model defined in OpenAPI""" # noqa: E501
|
||||
if local_vars_configuration is None:
|
||||
local_vars_configuration = Configuration()
|
||||
self.local_vars_configuration = local_vars_configuration
|
||||
|
||||
self._fields = None
|
||||
self.discriminator = None
|
||||
|
||||
if fields is not None:
|
||||
self.fields = fields
|
||||
|
||||
@property
|
||||
def fields(self):
|
||||
"""Gets the fields of this ProtobufStruct. # noqa: E501
|
||||
|
||||
Unordered map of dynamically typed values. # noqa: E501
|
||||
|
||||
:return: The fields of this ProtobufStruct. # noqa: E501
|
||||
:rtype: dict(str, ProtobufValue)
|
||||
"""
|
||||
return self._fields
|
||||
|
||||
@fields.setter
|
||||
def fields(self, fields):
|
||||
"""Sets the fields of this ProtobufStruct.
|
||||
|
||||
Unordered map of dynamically typed values. # noqa: E501
|
||||
|
||||
:param fields: The fields of this ProtobufStruct. # noqa: E501
|
||||
:type fields: dict(str, ProtobufValue)
|
||||
"""
|
||||
|
||||
self._fields = fields
|
||||
|
||||
def to_dict(self):
|
||||
"""Returns the model properties as a dict"""
|
||||
result = {}
|
||||
|
||||
for attr, _ in six.iteritems(self.openapi_types):
|
||||
value = getattr(self, attr)
|
||||
if isinstance(value, list):
|
||||
result[attr] = list(map(
|
||||
lambda x: x.to_dict() if hasattr(x, "to_dict") else x,
|
||||
value
|
||||
))
|
||||
elif hasattr(value, "to_dict"):
|
||||
result[attr] = value.to_dict()
|
||||
elif isinstance(value, dict):
|
||||
result[attr] = dict(map(
|
||||
lambda item: (item[0], item[1].to_dict())
|
||||
if hasattr(item[1], "to_dict") else item,
|
||||
value.items()
|
||||
))
|
||||
else:
|
||||
result[attr] = value
|
||||
|
||||
return result
|
||||
|
||||
def to_str(self):
|
||||
"""Returns the string representation of the model"""
|
||||
return pprint.pformat(self.to_dict())
|
||||
|
||||
def __repr__(self):
|
||||
"""For `print` and `pprint`"""
|
||||
return self.to_str()
|
||||
|
||||
def __eq__(self, other):
|
||||
"""Returns true if both objects are equal"""
|
||||
if not isinstance(other, ProtobufStruct):
|
||||
return False
|
||||
|
||||
return self.to_dict() == other.to_dict()
|
||||
|
||||
def __ne__(self, other):
|
||||
"""Returns true if both objects are not equal"""
|
||||
if not isinstance(other, ProtobufStruct):
|
||||
return True
|
||||
|
||||
return self.to_dict() != other.to_dict()
|
||||
|
|
@ -1,256 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
import pprint
|
||||
import re # noqa: F401
|
||||
|
||||
import six
|
||||
|
||||
from kfp_server_api.configuration import Configuration
|
||||
|
||||
|
||||
class ProtobufValue(object):
|
||||
"""NOTE: This class is auto generated by OpenAPI Generator.
|
||||
Ref: https://openapi-generator.tech
|
||||
|
||||
Do not edit the class manually.
|
||||
"""
|
||||
|
||||
"""
|
||||
Attributes:
|
||||
openapi_types (dict): The key is attribute name
|
||||
and the value is attribute type.
|
||||
attribute_map (dict): The key is attribute name
|
||||
and the value is json key in definition.
|
||||
"""
|
||||
openapi_types = {
|
||||
'null_value': 'ProtobufNullValue',
|
||||
'number_value': 'float',
|
||||
'string_value': 'str',
|
||||
'bool_value': 'bool',
|
||||
'struct_value': 'ProtobufStruct',
|
||||
'list_value': 'ProtobufListValue'
|
||||
}
|
||||
|
||||
attribute_map = {
|
||||
'null_value': 'null_value',
|
||||
'number_value': 'number_value',
|
||||
'string_value': 'string_value',
|
||||
'bool_value': 'bool_value',
|
||||
'struct_value': 'struct_value',
|
||||
'list_value': 'list_value'
|
||||
}
|
||||
|
||||
def __init__(self, null_value=None, number_value=None, string_value=None, bool_value=None, struct_value=None, list_value=None, local_vars_configuration=None): # noqa: E501
|
||||
"""ProtobufValue - a model defined in OpenAPI""" # noqa: E501
|
||||
if local_vars_configuration is None:
|
||||
local_vars_configuration = Configuration()
|
||||
self.local_vars_configuration = local_vars_configuration
|
||||
|
||||
self._null_value = None
|
||||
self._number_value = None
|
||||
self._string_value = None
|
||||
self._bool_value = None
|
||||
self._struct_value = None
|
||||
self._list_value = None
|
||||
self.discriminator = None
|
||||
|
||||
if null_value is not None:
|
||||
self.null_value = null_value
|
||||
if number_value is not None:
|
||||
self.number_value = number_value
|
||||
if string_value is not None:
|
||||
self.string_value = string_value
|
||||
if bool_value is not None:
|
||||
self.bool_value = bool_value
|
||||
if struct_value is not None:
|
||||
self.struct_value = struct_value
|
||||
if list_value is not None:
|
||||
self.list_value = list_value
|
||||
|
||||
@property
|
||||
def null_value(self):
|
||||
"""Gets the null_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
|
||||
:return: The null_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: ProtobufNullValue
|
||||
"""
|
||||
return self._null_value
|
||||
|
||||
@null_value.setter
|
||||
def null_value(self, null_value):
|
||||
"""Sets the null_value of this ProtobufValue.
|
||||
|
||||
|
||||
:param null_value: The null_value of this ProtobufValue. # noqa: E501
|
||||
:type null_value: ProtobufNullValue
|
||||
"""
|
||||
|
||||
self._null_value = null_value
|
||||
|
||||
@property
|
||||
def number_value(self):
|
||||
"""Gets the number_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
Represents a double value. # noqa: E501
|
||||
|
||||
:return: The number_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: float
|
||||
"""
|
||||
return self._number_value
|
||||
|
||||
@number_value.setter
|
||||
def number_value(self, number_value):
|
||||
"""Sets the number_value of this ProtobufValue.
|
||||
|
||||
Represents a double value. # noqa: E501
|
||||
|
||||
:param number_value: The number_value of this ProtobufValue. # noqa: E501
|
||||
:type number_value: float
|
||||
"""
|
||||
|
||||
self._number_value = number_value
|
||||
|
||||
@property
|
||||
def string_value(self):
|
||||
"""Gets the string_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
Represents a string value. # noqa: E501
|
||||
|
||||
:return: The string_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: str
|
||||
"""
|
||||
return self._string_value
|
||||
|
||||
@string_value.setter
|
||||
def string_value(self, string_value):
|
||||
"""Sets the string_value of this ProtobufValue.
|
||||
|
||||
Represents a string value. # noqa: E501
|
||||
|
||||
:param string_value: The string_value of this ProtobufValue. # noqa: E501
|
||||
:type string_value: str
|
||||
"""
|
||||
|
||||
self._string_value = string_value
|
||||
|
||||
@property
|
||||
def bool_value(self):
|
||||
"""Gets the bool_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
Represents a boolean value. # noqa: E501
|
||||
|
||||
:return: The bool_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: bool
|
||||
"""
|
||||
return self._bool_value
|
||||
|
||||
@bool_value.setter
|
||||
def bool_value(self, bool_value):
|
||||
"""Sets the bool_value of this ProtobufValue.
|
||||
|
||||
Represents a boolean value. # noqa: E501
|
||||
|
||||
:param bool_value: The bool_value of this ProtobufValue. # noqa: E501
|
||||
:type bool_value: bool
|
||||
"""
|
||||
|
||||
self._bool_value = bool_value
|
||||
|
||||
@property
|
||||
def struct_value(self):
|
||||
"""Gets the struct_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
|
||||
:return: The struct_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: ProtobufStruct
|
||||
"""
|
||||
return self._struct_value
|
||||
|
||||
@struct_value.setter
|
||||
def struct_value(self, struct_value):
|
||||
"""Sets the struct_value of this ProtobufValue.
|
||||
|
||||
|
||||
:param struct_value: The struct_value of this ProtobufValue. # noqa: E501
|
||||
:type struct_value: ProtobufStruct
|
||||
"""
|
||||
|
||||
self._struct_value = struct_value
|
||||
|
||||
@property
|
||||
def list_value(self):
|
||||
"""Gets the list_value of this ProtobufValue. # noqa: E501
|
||||
|
||||
|
||||
:return: The list_value of this ProtobufValue. # noqa: E501
|
||||
:rtype: ProtobufListValue
|
||||
"""
|
||||
return self._list_value
|
||||
|
||||
@list_value.setter
|
||||
def list_value(self, list_value):
|
||||
"""Sets the list_value of this ProtobufValue.
|
||||
|
||||
|
||||
:param list_value: The list_value of this ProtobufValue. # noqa: E501
|
||||
:type list_value: ProtobufListValue
|
||||
"""
|
||||
|
||||
self._list_value = list_value
|
||||
|
||||
def to_dict(self):
|
||||
"""Returns the model properties as a dict"""
|
||||
result = {}
|
||||
|
||||
for attr, _ in six.iteritems(self.openapi_types):
|
||||
value = getattr(self, attr)
|
||||
if isinstance(value, list):
|
||||
result[attr] = list(map(
|
||||
lambda x: x.to_dict() if hasattr(x, "to_dict") else x,
|
||||
value
|
||||
))
|
||||
elif hasattr(value, "to_dict"):
|
||||
result[attr] = value.to_dict()
|
||||
elif isinstance(value, dict):
|
||||
result[attr] = dict(map(
|
||||
lambda item: (item[0], item[1].to_dict())
|
||||
if hasattr(item[1], "to_dict") else item,
|
||||
value.items()
|
||||
))
|
||||
else:
|
||||
result[attr] = value
|
||||
|
||||
return result
|
||||
|
||||
def to_str(self):
|
||||
"""Returns the string representation of the model"""
|
||||
return pprint.pformat(self.to_dict())
|
||||
|
||||
def __repr__(self):
|
||||
"""For `print` and `pprint`"""
|
||||
return self.to_str()
|
||||
|
||||
def __eq__(self, other):
|
||||
"""Returns true if both objects are equal"""
|
||||
if not isinstance(other, ProtobufValue):
|
||||
return False
|
||||
|
||||
return self.to_dict() == other.to_dict()
|
||||
|
||||
def __ne__(self, other):
|
||||
"""Returns true if both objects are not equal"""
|
||||
if not isinstance(other, ProtobufValue):
|
||||
return True
|
||||
|
||||
return self.to_dict() != other.to_dict()
|
||||
|
|
@ -13,7 +13,7 @@
|
|||
from setuptools import setup, find_packages # noqa: H301
|
||||
|
||||
NAME = "kfp-server-api"
|
||||
VERSION = "2.0.0-beta.1"
|
||||
VERSION = "2.0.0-beta.2"
|
||||
# To install the library, run the following
|
||||
#
|
||||
# python setup.py install
|
||||
|
|
|
|||
|
|
@ -51,26 +51,7 @@ class TestApiJob(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', ), ),
|
||||
resource_references = [
|
||||
|
|
|
|||
|
|
@ -53,26 +53,7 @@ class TestApiListJobsResponse(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', ), ),
|
||||
resource_references = [
|
||||
|
|
|
|||
|
|
@ -54,26 +54,7 @@ class TestApiListRunsResponse(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', ), ),
|
||||
resource_references = [
|
||||
|
|
|
|||
|
|
@ -47,26 +47,7 @@ class TestApiPipelineSpec(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', )
|
||||
)
|
||||
|
|
|
|||
|
|
@ -52,26 +52,7 @@ class TestApiRun(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', ), ),
|
||||
resource_references = [
|
||||
|
|
|
|||
|
|
@ -53,26 +53,7 @@ class TestApiRunDetail(unittest.TestCase):
|
|||
],
|
||||
runtime_config = kfp_server_api.models.pipeline_spec_runtime_config.PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0', ), ),
|
||||
resource_references = [
|
||||
|
|
|
|||
|
|
@ -37,26 +37,7 @@ class TestPipelineSpecRuntimeConfig(unittest.TestCase):
|
|||
if include_optional :
|
||||
return PipelineSpecRuntimeConfig(
|
||||
parameters = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
'key' : None
|
||||
},
|
||||
pipeline_root = '0'
|
||||
)
|
||||
|
|
|
|||
|
|
@ -1,67 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
from __future__ import absolute_import
|
||||
|
||||
import unittest
|
||||
import datetime
|
||||
|
||||
import kfp_server_api
|
||||
from kfp_server_api.models.protobuf_list_value import ProtobufListValue # noqa: E501
|
||||
from kfp_server_api.rest import ApiException
|
||||
|
||||
class TestProtobufListValue(unittest.TestCase):
|
||||
"""ProtobufListValue unit test stubs"""
|
||||
|
||||
def setUp(self):
|
||||
pass
|
||||
|
||||
def tearDown(self):
|
||||
pass
|
||||
|
||||
def make_instance(self, include_optional):
|
||||
"""Test ProtobufListValue
|
||||
include_option is a boolean, when False only required
|
||||
params are included, when True both required and
|
||||
optional params are included """
|
||||
# model = kfp_server_api.models.protobuf_list_value.ProtobufListValue() # noqa: E501
|
||||
if include_optional :
|
||||
return ProtobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(), )
|
||||
]
|
||||
)
|
||||
else :
|
||||
return ProtobufListValue(
|
||||
)
|
||||
|
||||
def testProtobufListValue(self):
|
||||
"""Test ProtobufListValue"""
|
||||
inst_req_only = self.make_instance(include_optional=False)
|
||||
inst_req_and_optional = self.make_instance(include_optional=True)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
|
@ -1,66 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
from __future__ import absolute_import
|
||||
|
||||
import unittest
|
||||
import datetime
|
||||
|
||||
import kfp_server_api
|
||||
from kfp_server_api.models.protobuf_struct import ProtobufStruct # noqa: E501
|
||||
from kfp_server_api.rest import ApiException
|
||||
|
||||
class TestProtobufStruct(unittest.TestCase):
|
||||
"""ProtobufStruct unit test stubs"""
|
||||
|
||||
def setUp(self):
|
||||
pass
|
||||
|
||||
def tearDown(self):
|
||||
pass
|
||||
|
||||
def make_instance(self, include_optional):
|
||||
"""Test ProtobufStruct
|
||||
include_option is a boolean, when False only required
|
||||
params are included, when True both required and
|
||||
optional params are included """
|
||||
# model = kfp_server_api.models.protobuf_struct.ProtobufStruct() # noqa: E501
|
||||
if include_optional :
|
||||
return ProtobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}
|
||||
)
|
||||
else :
|
||||
return ProtobufStruct(
|
||||
)
|
||||
|
||||
def testProtobufStruct(self):
|
||||
"""Test ProtobufStruct"""
|
||||
inst_req_only = self.make_instance(include_optional=False)
|
||||
inst_req_and_optional = self.make_instance(include_optional=True)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
|
@ -1,85 +0,0 @@
|
|||
# coding: utf-8
|
||||
|
||||
"""
|
||||
Kubeflow Pipelines API
|
||||
|
||||
This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.
|
||||
|
||||
Contact: kubeflow-pipelines@google.com
|
||||
Generated by: https://openapi-generator.tech
|
||||
"""
|
||||
|
||||
|
||||
from __future__ import absolute_import
|
||||
|
||||
import unittest
|
||||
import datetime
|
||||
|
||||
import kfp_server_api
|
||||
from kfp_server_api.models.protobuf_value import ProtobufValue # noqa: E501
|
||||
from kfp_server_api.rest import ApiException
|
||||
|
||||
class TestProtobufValue(unittest.TestCase):
|
||||
"""ProtobufValue unit test stubs"""
|
||||
|
||||
def setUp(self):
|
||||
pass
|
||||
|
||||
def tearDown(self):
|
||||
pass
|
||||
|
||||
def make_instance(self, include_optional):
|
||||
"""Test ProtobufValue
|
||||
include_option is a boolean, when False only required
|
||||
params are included, when True both required and
|
||||
optional params are included """
|
||||
# model = kfp_server_api.models.protobuf_value.ProtobufValue() # noqa: E501
|
||||
if include_optional :
|
||||
return ProtobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
], ), )
|
||||
}, ),
|
||||
list_value = kfp_server_api.models.protobuf_list_value.protobufListValue(
|
||||
values = [
|
||||
kfp_server_api.models.protobuf_value.protobufValue(
|
||||
null_value = 'NULL_VALUE',
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True,
|
||||
struct_value = kfp_server_api.models.protobuf_struct.protobufStruct(
|
||||
fields = {
|
||||
'key' : kfp_server_api.models.protobuf_value.protobufValue(
|
||||
number_value = 1.337,
|
||||
string_value = '0',
|
||||
bool_value = True, )
|
||||
}, ), )
|
||||
], )
|
||||
)
|
||||
else :
|
||||
return ProtobufValue(
|
||||
)
|
||||
|
||||
def testProtobufValue(self):
|
||||
"""Test ProtobufValue"""
|
||||
inst_req_only = self.make_instance(include_optional=False)
|
||||
inst_req_and_optional = self.make_instance(include_optional=True)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
|
@ -268,7 +268,7 @@
|
|||
"parameters": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
"type": "object"
|
||||
},
|
||||
"description": "The runtime parameters of the PipelineSpec. The parameters will be\nused to replace the placeholders\nat runtime."
|
||||
},
|
||||
|
|
@ -551,19 +551,6 @@
|
|||
},
|
||||
"description": "`Any` contains an arbitrary serialized protocol buffer message along with a\nURL that describes the type of the serialized message.\n\nProtobuf library provides support to pack/unpack Any values in the form\nof utility functions or additional generated methods of the Any type.\n\nExample 1: Pack and unpack a message in C++.\n\n Foo foo = ...;\n Any any;\n any.PackFrom(foo);\n ...\n if (any.UnpackTo(\u0026foo)) {\n ...\n }\n\nExample 2: Pack and unpack a message in Java.\n\n Foo foo = ...;\n Any any = Any.pack(foo);\n ...\n if (any.is(Foo.class)) {\n foo = any.unpack(Foo.class);\n }\n\n Example 3: Pack and unpack a message in Python.\n\n foo = Foo(...)\n any = Any()\n any.Pack(foo)\n ...\n if any.Is(Foo.DESCRIPTOR):\n any.Unpack(foo)\n ...\n\n Example 4: Pack and unpack a message in Go\n\n foo := \u0026pb.Foo{...}\n any, err := anypb.New(foo)\n if err != nil {\n ...\n }\n ...\n foo := \u0026pb.Foo{}\n if err := any.UnmarshalTo(foo); err != nil {\n ...\n }\n\nThe pack methods provided by protobuf library will by default use\n'type.googleapis.com/full.type.name' as the type URL and the unpack\nmethods only use the fully qualified type name after the last '/'\nin the type URL, for example \"foo.bar.com/x/y.z\" will yield type\nname \"y.z\".\n\n\nJSON\n====\nThe JSON representation of an `Any` value uses the regular\nrepresentation of the deserialized, embedded message, with an\nadditional field `@type` which contains the type URL. Example:\n\n package google.profile;\n message Person {\n string first_name = 1;\n string last_name = 2;\n }\n\n {\n \"@type\": \"type.googleapis.com/google.profile.Person\",\n \"firstName\": \u003cstring\u003e,\n \"lastName\": \u003cstring\u003e\n }\n\nIf the embedded message type is well-known and has a custom JSON\nrepresentation, that representation will be embedded adding a field\n`value` which holds the custom JSON in addition to the `@type`\nfield. Example (for message [google.protobuf.Duration][]):\n\n {\n \"@type\": \"type.googleapis.com/google.protobuf.Duration\",\n \"value\": \"1.212s\"\n }"
|
||||
},
|
||||
"protobufListValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"values": {
|
||||
"type": "array",
|
||||
"items": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Repeated field of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`ListValue` is a wrapper around a repeated field of values.\n\nThe JSON representation for `ListValue` is JSON array."
|
||||
},
|
||||
"protobufNullValue": {
|
||||
"type": "string",
|
||||
"enum": [
|
||||
|
|
@ -571,51 +558,6 @@
|
|||
],
|
||||
"default": "NULL_VALUE",
|
||||
"description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value."
|
||||
},
|
||||
"protobufStruct": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"fields": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Unordered map of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`Struct` represents a structured data value, consisting of fields\nwhich map to dynamically typed values. In some languages, `Struct`\nmight be supported by a native representation. For example, in\nscripting languages like JS a struct is represented as an\nobject. The details of that representation are described together\nwith the proto support for the language.\n\nThe JSON representation for `Struct` is JSON object."
|
||||
},
|
||||
"protobufValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"null_value": {
|
||||
"$ref": "#/definitions/protobufNullValue",
|
||||
"description": "Represents a null value."
|
||||
},
|
||||
"number_value": {
|
||||
"type": "number",
|
||||
"format": "double",
|
||||
"description": "Represents a double value."
|
||||
},
|
||||
"string_value": {
|
||||
"type": "string",
|
||||
"description": "Represents a string value."
|
||||
},
|
||||
"bool_value": {
|
||||
"type": "boolean",
|
||||
"format": "boolean",
|
||||
"description": "Represents a boolean value."
|
||||
},
|
||||
"struct_value": {
|
||||
"$ref": "#/definitions/protobufStruct",
|
||||
"description": "Represents a structured value."
|
||||
},
|
||||
"list_value": {
|
||||
"$ref": "#/definitions/protobufListValue",
|
||||
"description": "Represents a repeated `Value`."
|
||||
}
|
||||
},
|
||||
"description": "`Value` represents a dynamically typed value which can be either\nnull, a number, a string, a boolean, a recursive struct value, or a\nlist of values. A producer of value is expected to set one of that\nvariants, absence of any variant indicates an error.\n\nThe JSON representation for `Value` is JSON value."
|
||||
}
|
||||
},
|
||||
"securityDefinitions": {
|
||||
|
|
|
|||
|
|
@ -2,7 +2,7 @@
|
|||
"swagger": "2.0",
|
||||
"info": {
|
||||
"title": "Kubeflow Pipelines API",
|
||||
"version": "2.0.0-beta.1",
|
||||
"version": "2.0.0-beta.2",
|
||||
"description": "This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.",
|
||||
"contact": {
|
||||
"name": "google",
|
||||
|
|
@ -1657,7 +1657,7 @@
|
|||
"parameters": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
"type": "object"
|
||||
},
|
||||
"description": "The runtime parameters of the PipelineSpec. The parameters will be\nused to replace the placeholders\nat runtime."
|
||||
},
|
||||
|
|
@ -1931,19 +1931,6 @@
|
|||
],
|
||||
"default": "STORAGESTATE_AVAILABLE"
|
||||
},
|
||||
"protobufListValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"values": {
|
||||
"type": "array",
|
||||
"items": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Repeated field of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`ListValue` is a wrapper around a repeated field of values.\n\nThe JSON representation for `ListValue` is JSON array."
|
||||
},
|
||||
"protobufNullValue": {
|
||||
"type": "string",
|
||||
"enum": [
|
||||
|
|
@ -1952,51 +1939,6 @@
|
|||
"default": "NULL_VALUE",
|
||||
"description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value."
|
||||
},
|
||||
"protobufStruct": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"fields": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Unordered map of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`Struct` represents a structured data value, consisting of fields\nwhich map to dynamically typed values. In some languages, `Struct`\nmight be supported by a native representation. For example, in\nscripting languages like JS a struct is represented as an\nobject. The details of that representation are described together\nwith the proto support for the language.\n\nThe JSON representation for `Struct` is JSON object."
|
||||
},
|
||||
"protobufValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"null_value": {
|
||||
"$ref": "#/definitions/protobufNullValue",
|
||||
"description": "Represents a null value."
|
||||
},
|
||||
"number_value": {
|
||||
"type": "number",
|
||||
"format": "double",
|
||||
"description": "Represents a double value."
|
||||
},
|
||||
"string_value": {
|
||||
"type": "string",
|
||||
"description": "Represents a string value."
|
||||
},
|
||||
"bool_value": {
|
||||
"type": "boolean",
|
||||
"format": "boolean",
|
||||
"description": "Represents a boolean value."
|
||||
},
|
||||
"struct_value": {
|
||||
"$ref": "#/definitions/protobufStruct",
|
||||
"description": "Represents a structured value."
|
||||
},
|
||||
"list_value": {
|
||||
"$ref": "#/definitions/protobufListValue",
|
||||
"description": "Represents a repeated `Value`."
|
||||
}
|
||||
},
|
||||
"description": "`Value` represents a dynamically typed value which can be either\nnull, a number, a string, a boolean, a recursive struct value, or a\nlist of values. A producer of value is expected to set one of that\nvariants, absence of any variant indicates an error.\n\nThe JSON representation for `Value` is JSON value."
|
||||
},
|
||||
"JobMode": {
|
||||
"type": "string",
|
||||
"enum": [
|
||||
|
|
|
|||
|
|
@ -409,7 +409,7 @@
|
|||
"parameters": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
"type": "object"
|
||||
},
|
||||
"description": "The runtime parameters of the PipelineSpec. The parameters will be\nused to replace the placeholders\nat runtime."
|
||||
},
|
||||
|
|
@ -766,19 +766,6 @@
|
|||
},
|
||||
"description": "`Any` contains an arbitrary serialized protocol buffer message along with a\nURL that describes the type of the serialized message.\n\nProtobuf library provides support to pack/unpack Any values in the form\nof utility functions or additional generated methods of the Any type.\n\nExample 1: Pack and unpack a message in C++.\n\n Foo foo = ...;\n Any any;\n any.PackFrom(foo);\n ...\n if (any.UnpackTo(\u0026foo)) {\n ...\n }\n\nExample 2: Pack and unpack a message in Java.\n\n Foo foo = ...;\n Any any = Any.pack(foo);\n ...\n if (any.is(Foo.class)) {\n foo = any.unpack(Foo.class);\n }\n\n Example 3: Pack and unpack a message in Python.\n\n foo = Foo(...)\n any = Any()\n any.Pack(foo)\n ...\n if any.Is(Foo.DESCRIPTOR):\n any.Unpack(foo)\n ...\n\n Example 4: Pack and unpack a message in Go\n\n foo := \u0026pb.Foo{...}\n any, err := anypb.New(foo)\n if err != nil {\n ...\n }\n ...\n foo := \u0026pb.Foo{}\n if err := any.UnmarshalTo(foo); err != nil {\n ...\n }\n\nThe pack methods provided by protobuf library will by default use\n'type.googleapis.com/full.type.name' as the type URL and the unpack\nmethods only use the fully qualified type name after the last '/'\nin the type URL, for example \"foo.bar.com/x/y.z\" will yield type\nname \"y.z\".\n\n\nJSON\n====\nThe JSON representation of an `Any` value uses the regular\nrepresentation of the deserialized, embedded message, with an\nadditional field `@type` which contains the type URL. Example:\n\n package google.profile;\n message Person {\n string first_name = 1;\n string last_name = 2;\n }\n\n {\n \"@type\": \"type.googleapis.com/google.profile.Person\",\n \"firstName\": \u003cstring\u003e,\n \"lastName\": \u003cstring\u003e\n }\n\nIf the embedded message type is well-known and has a custom JSON\nrepresentation, that representation will be embedded adding a field\n`value` which holds the custom JSON in addition to the `@type`\nfield. Example (for message [google.protobuf.Duration][]):\n\n {\n \"@type\": \"type.googleapis.com/google.protobuf.Duration\",\n \"value\": \"1.212s\"\n }"
|
||||
},
|
||||
"protobufListValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"values": {
|
||||
"type": "array",
|
||||
"items": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Repeated field of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`ListValue` is a wrapper around a repeated field of values.\n\nThe JSON representation for `ListValue` is JSON array."
|
||||
},
|
||||
"protobufNullValue": {
|
||||
"type": "string",
|
||||
"enum": [
|
||||
|
|
@ -786,51 +773,6 @@
|
|||
],
|
||||
"default": "NULL_VALUE",
|
||||
"description": "`NullValue` is a singleton enumeration to represent the null value for the\n`Value` type union.\n\n The JSON representation for `NullValue` is JSON `null`.\n\n - NULL_VALUE: Null value."
|
||||
},
|
||||
"protobufStruct": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"fields": {
|
||||
"type": "object",
|
||||
"additionalProperties": {
|
||||
"$ref": "#/definitions/protobufValue"
|
||||
},
|
||||
"description": "Unordered map of dynamically typed values."
|
||||
}
|
||||
},
|
||||
"description": "`Struct` represents a structured data value, consisting of fields\nwhich map to dynamically typed values. In some languages, `Struct`\nmight be supported by a native representation. For example, in\nscripting languages like JS a struct is represented as an\nobject. The details of that representation are described together\nwith the proto support for the language.\n\nThe JSON representation for `Struct` is JSON object."
|
||||
},
|
||||
"protobufValue": {
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"null_value": {
|
||||
"$ref": "#/definitions/protobufNullValue",
|
||||
"description": "Represents a null value."
|
||||
},
|
||||
"number_value": {
|
||||
"type": "number",
|
||||
"format": "double",
|
||||
"description": "Represents a double value."
|
||||
},
|
||||
"string_value": {
|
||||
"type": "string",
|
||||
"description": "Represents a string value."
|
||||
},
|
||||
"bool_value": {
|
||||
"type": "boolean",
|
||||
"format": "boolean",
|
||||
"description": "Represents a boolean value."
|
||||
},
|
||||
"struct_value": {
|
||||
"$ref": "#/definitions/protobufStruct",
|
||||
"description": "Represents a structured value."
|
||||
},
|
||||
"list_value": {
|
||||
"$ref": "#/definitions/protobufListValue",
|
||||
"description": "Represents a repeated `Value`."
|
||||
}
|
||||
},
|
||||
"description": "`Value` represents a dynamically typed value which can be either\nnull, a number, a string, a boolean, a recursive struct value, or a\nlist of values. A producer of value is expected to set one of that\nvariants, absence of any variant indicates an error.\n\nThe JSON representation for `Value` is JSON value."
|
||||
}
|
||||
},
|
||||
"securityDefinitions": {
|
||||
|
|
|
|||
|
|
@ -3,8 +3,8 @@ This file contains REST API specification for Kubeflow Pipelines. The file is au
|
|||
|
||||
This Python package is automatically generated by the [OpenAPI Generator](https://openapi-generator.tech) project:
|
||||
|
||||
- API version: 2.0.0-beta.1
|
||||
- Package version: 2.0.0-beta.1
|
||||
- API version: 2.0.0-beta.2
|
||||
- Package version: 2.0.0-beta.2
|
||||
- Build package: org.openapitools.codegen.languages.PythonClientCodegen
|
||||
For more information, please visit [https://www.google.com](https://www.google.com)
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@
|
|||
|
||||
from __future__ import absolute_import
|
||||
|
||||
__version__ = "2.0.0-beta.1"
|
||||
__version__ = "2.0.0-beta.2"
|
||||
|
||||
# import apis into sdk package
|
||||
from kfp_server_api.api.auth_service_api import AuthServiceApi
|
||||
|
|
|
|||
|
|
@ -78,7 +78,7 @@ class ApiClient(object):
|
|||
self.default_headers[header_name] = header_value
|
||||
self.cookie = cookie
|
||||
# Set default User-Agent.
|
||||
self.user_agent = 'OpenAPI-Generator/2.0.0-beta.1/python'
|
||||
self.user_agent = 'OpenAPI-Generator/2.0.0-beta.2/python'
|
||||
self.client_side_validation = configuration.client_side_validation
|
||||
|
||||
def __enter__(self):
|
||||
|
|
|
|||
|
|
@ -351,8 +351,8 @@ conf = kfp_server_api.Configuration(
|
|||
return "Python SDK Debug Report:\n"\
|
||||
"OS: {env}\n"\
|
||||
"Python Version: {pyversion}\n"\
|
||||
"Version of the API: 2.0.0-beta.1\n"\
|
||||
"SDK Package Version: 2.0.0-beta.1".\
|
||||
"Version of the API: 2.0.0-beta.2\n"\
|
||||
"SDK Package Version: 2.0.0-beta.2".\
|
||||
format(env=sys.platform, pyversion=sys.version)
|
||||
|
||||
def get_host_settings(self):
|
||||
|
|
|
|||
|
|
@ -13,7 +13,7 @@
|
|||
from setuptools import setup, find_packages # noqa: H301
|
||||
|
||||
NAME = "kfp-server-api"
|
||||
VERSION = "2.0.0-beta.1"
|
||||
VERSION = "2.0.0-beta.2"
|
||||
# To install the library, run the following
|
||||
#
|
||||
# python setup.py install
|
||||
|
|
|
|||
|
|
@ -2,7 +2,7 @@
|
|||
"swagger": "2.0",
|
||||
"info": {
|
||||
"title": "Kubeflow Pipelines API",
|
||||
"version": "2.0.0-beta.1",
|
||||
"version": "2.0.0-beta.2",
|
||||
"description": "This file contains REST API specification for Kubeflow Pipelines. The file is autogenerated from the swagger definition.",
|
||||
"contact": {
|
||||
"name": "google",
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ metadata:
|
|||
spec:
|
||||
descriptor:
|
||||
type: Kubeflow Pipelines
|
||||
version: 2.0.0-beta.1
|
||||
version: 2.0.0-beta.2
|
||||
description: |-
|
||||
Reusable end-to-end ML workflow
|
||||
maintainers:
|
||||
|
|
|
|||
|
|
@ -1,9 +1,9 @@
|
|||
x-google-marketplace:
|
||||
schemaVersion: v2
|
||||
applicationApiVersion: v1beta1
|
||||
publishedVersion: 2.0.0-beta.1
|
||||
publishedVersion: 2.0.0-beta.2
|
||||
publishedVersionMetadata:
|
||||
releaseNote: Based on 2.0.0-beta.1 version.
|
||||
releaseNote: Based on 2.0.0-beta.2 version.
|
||||
releaseTypes:
|
||||
- Feature
|
||||
recommended: false
|
||||
|
|
|
|||
|
|
@ -8,4 +8,4 @@ commonLabels:
|
|||
app: cache-deployer
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/cache-deployer
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
|
|
|
|||
|
|
@ -10,4 +10,4 @@ commonLabels:
|
|||
app: cache-server
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/cache-server
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ data:
|
|||
until the changes take effect. A quick way to restart all deployments in a
|
||||
namespace: `kubectl rollout restart deployment -n <your-namespace>`.
|
||||
appName: pipeline
|
||||
appVersion: 2.0.0-beta.1
|
||||
appVersion: 2.0.0-beta.2
|
||||
dbHost: mysql
|
||||
dbPort: "3306"
|
||||
mlmdDb: metadb
|
||||
|
|
|
|||
|
|
@ -9,4 +9,4 @@ resources:
|
|||
- metadata-grpc-sa.yaml
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/metadata-envoy
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
|
|
|
|||
|
|
@ -37,14 +37,14 @@ resources:
|
|||
- kfp-launcher-configmap.yaml
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/api-server
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
- name: gcr.io/ml-pipeline/persistenceagent
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
- name: gcr.io/ml-pipeline/scheduledworkflow
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
- name: gcr.io/ml-pipeline/frontend
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
- name: gcr.io/ml-pipeline/viewer-crd-controller
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
- name: gcr.io/ml-pipeline/visualization-server
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
|
|
|
|||
|
|
@ -7,4 +7,4 @@ resources:
|
|||
- metadata-writer-sa.yaml
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/metadata-writer
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
|
|
|
|||
|
|
@ -2,7 +2,7 @@ apiVersion: kustomize.config.k8s.io/v1beta1
|
|||
kind: Kustomization
|
||||
images:
|
||||
- name: gcr.io/ml-pipeline/inverse-proxy-agent
|
||||
newTag: 2.0.0-beta.1
|
||||
newTag: 2.0.0-beta.2
|
||||
resources:
|
||||
- proxy-configmap.yaml
|
||||
- proxy-deployment.yaml
|
||||
|
|
|
|||
Loading…
Reference in New Issue