From 4a9bc2b1ca33d4eccc7d0dc5c1aced09b9b10a02 Mon Sep 17 00:00:00 2001 From: Chen Sun Date: Wed, 5 Apr 2023 11:05:02 -0700 Subject: [PATCH] fix(api): Fix pipeline.upload.swagger.json (#9104) * fix pipeline.upload.swagger.json * remove `namespace` from upload_pipeline_version parameters --- .../upload_pipeline_responses.go | 8 +- .../upload_pipeline_version_parameters.go | 29 - .../upload_pipeline_version_responses.go | 8 +- .../pipeline_upload_model/api_parameter.go | 46 -- .../pipeline_upload_model/api_pipeline.go | 116 ---- .../api_pipeline_version.go | 171 ------ .../pipeline_upload_model/api_relationship.go | 66 --- .../pipeline_upload_model/api_resource_key.go | 72 --- .../api_resource_reference.go | 97 ---- .../api_resource_type.go | 75 --- .../pipeline_upload_model/api_status.go | 86 --- .../pipeline_upload_model/googlerpc_status.go | 95 ++++ .../pipeline_upload_model/v2beta1_pipeline.go | 109 ++++ .../v2beta1_pipeline_version.go | 144 +++++ .../{api_url.go => v2beta1_url.go} | 18 +- .../api/v2beta1/python_http_client/README.md | 9 - .../python_http_client/docs/ApiParameter.md | 11 - .../python_http_client/docs/ApiPipeline.md | 15 - .../docs/ApiPipelineVersion.md | 16 - .../docs/ApiRelationship.md | 9 - .../python_http_client/docs/ApiResourceKey.md | 11 - .../docs/ApiResourceReference.md | 12 - .../docs/ApiResourceType.md | 9 - .../python_http_client/docs/ApiStatus.md | 12 - .../v2beta1/python_http_client/docs/ApiUrl.md | 10 - .../docs/PipelineUploadServiceApi.md | 12 +- .../kfp_server_api/__init__.py | 9 - .../api/pipeline_upload_service_api.py | 21 +- .../kfp_server_api/models/__init__.py | 9 - .../kfp_server_api/models/api_parameter.py | 146 ----- .../kfp_server_api/models/api_pipeline.py | 252 --------- .../models/api_pipeline_version.py | 288 ---------- .../kfp_server_api/models/api_relationship.py | 101 ---- .../kfp_server_api/models/api_resource_key.py | 148 ------ .../models/api_resource_reference.py | 174 ------ .../models/api_resource_type.py | 104 ---- .../kfp_server_api/models/api_status.py | 172 ------ .../kfp_server_api/models/api_url.py | 120 ----- .../test/test_api_parameter.py | 53 -- .../test/test_api_pipeline.py | 61 --- .../test/test_api_pipeline_version.py | 70 --- .../test/test_api_relationship.py | 51 -- .../test/test_api_resource_key.py | 53 -- .../test/test_api_resource_reference.py | 56 -- .../test/test_api_resource_type.py | 51 -- .../test/test_api_status.py | 58 -- .../python_http_client/test/test_api_url.py | 52 -- .../swagger/kfp_api_single_file.swagger.json | 169 +----- .../swagger/pipeline.upload.swagger.json | 503 ++++++++---------- 49 files changed, 596 insertions(+), 3391 deletions(-) delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_parameter.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline_version.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_relationship.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_key.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_reference.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_type.go delete mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/api_status.go create mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/googlerpc_status.go create mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline.go create mode 100644 backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline_version.go rename backend/api/v2beta1/go_http_client/pipeline_upload_model/{api_url.go => v2beta1_url.go} (62%) delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiParameter.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiPipeline.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiPipelineVersion.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiRelationship.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiResourceKey.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiResourceReference.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiResourceType.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiStatus.md delete mode 100644 backend/api/v2beta1/python_http_client/docs/ApiUrl.md delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_parameter.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline_version.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_relationship.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_key.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_reference.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_type.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_status.py delete mode 100644 backend/api/v2beta1/python_http_client/kfp_server_api/models/api_url.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_parameter.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_pipeline.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_pipeline_version.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_relationship.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_resource_key.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_resource_reference.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_resource_type.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_status.py delete mode 100644 backend/api/v2beta1/python_http_client/test/test_api_url.py diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go index 4343f8423d3..beccd61bfe4 100644 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go @@ -54,7 +54,7 @@ func NewUploadPipelineOK() *UploadPipelineOK { UploadPipelineOK upload pipeline o k */ type UploadPipelineOK struct { - Payload *pipeline_upload_model.APIPipeline + Payload *pipeline_upload_model.V2beta1Pipeline } func (o *UploadPipelineOK) Error() string { @@ -63,7 +63,7 @@ func (o *UploadPipelineOK) Error() string { func (o *UploadPipelineOK) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { - o.Payload = new(pipeline_upload_model.APIPipeline) + o.Payload = new(pipeline_upload_model.V2beta1Pipeline) // response payload if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF { @@ -87,7 +87,7 @@ UploadPipelineDefault upload pipeline default type UploadPipelineDefault struct { _statusCode int - Payload *pipeline_upload_model.APIStatus + Payload *pipeline_upload_model.GooglerpcStatus } // Code gets the status code for the upload pipeline default response @@ -101,7 +101,7 @@ func (o *UploadPipelineDefault) Error() string { func (o *UploadPipelineDefault) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { - o.Payload = new(pipeline_upload_model.APIStatus) + o.Payload = new(pipeline_upload_model.GooglerpcStatus) // response payload if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF { diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go index 863e9c58741..6a056609f74 100644 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go @@ -65,8 +65,6 @@ type UploadPipelineVersionParams struct { Description *string /*Name*/ Name *string - /*Namespace*/ - Namespace *string /*Pipelineid*/ Pipelineid *string /*Uploadfile @@ -135,17 +133,6 @@ func (o *UploadPipelineVersionParams) SetName(name *string) { o.Name = name } -// WithNamespace adds the namespace to the upload pipeline version params -func (o *UploadPipelineVersionParams) WithNamespace(namespace *string) *UploadPipelineVersionParams { - o.SetNamespace(namespace) - return o -} - -// SetNamespace adds the namespace to the upload pipeline version params -func (o *UploadPipelineVersionParams) SetNamespace(namespace *string) { - o.Namespace = namespace -} - // WithPipelineid adds the pipelineid to the upload pipeline version params func (o *UploadPipelineVersionParams) WithPipelineid(pipelineid *string) *UploadPipelineVersionParams { o.SetPipelineid(pipelineid) @@ -208,22 +195,6 @@ func (o *UploadPipelineVersionParams) WriteToRequest(r runtime.ClientRequest, re } - if o.Namespace != nil { - - // query param namespace - var qrNamespace string - if o.Namespace != nil { - qrNamespace = *o.Namespace - } - qNamespace := qrNamespace - if qNamespace != "" { - if err := r.SetQueryParam("namespace", qNamespace); err != nil { - return err - } - } - - } - if o.Pipelineid != nil { // query param pipelineid diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go index 74072cc7451..d7364ac772a 100644 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go @@ -54,7 +54,7 @@ func NewUploadPipelineVersionOK() *UploadPipelineVersionOK { UploadPipelineVersionOK upload pipeline version o k */ type UploadPipelineVersionOK struct { - Payload *pipeline_upload_model.APIPipelineVersion + Payload *pipeline_upload_model.V2beta1PipelineVersion } func (o *UploadPipelineVersionOK) Error() string { @@ -63,7 +63,7 @@ func (o *UploadPipelineVersionOK) Error() string { func (o *UploadPipelineVersionOK) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { - o.Payload = new(pipeline_upload_model.APIPipelineVersion) + o.Payload = new(pipeline_upload_model.V2beta1PipelineVersion) // response payload if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF { @@ -87,7 +87,7 @@ UploadPipelineVersionDefault upload pipeline version default type UploadPipelineVersionDefault struct { _statusCode int - Payload *pipeline_upload_model.APIStatus + Payload *pipeline_upload_model.GooglerpcStatus } // Code gets the status code for the upload pipeline version default response @@ -101,7 +101,7 @@ func (o *UploadPipelineVersionDefault) Error() string { func (o *UploadPipelineVersionDefault) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { - o.Payload = new(pipeline_upload_model.APIStatus) + o.Payload = new(pipeline_upload_model.GooglerpcStatus) // response payload if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF { diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_parameter.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_parameter.go deleted file mode 100644 index f46f394429a..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_parameter.go +++ /dev/null @@ -1,46 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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/swag" -) - -// APIParameter api parameter -// swagger:model apiParameter -type APIParameter struct { - - // name - Name string `json:"name,omitempty"` - - // value - Value string `json:"value,omitempty"` -} - -// Validate validates this api parameter -func (m *APIParameter) Validate(formats strfmt.Registry) error { - return nil -} - -// MarshalBinary interface implementation -func (m *APIParameter) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIParameter) UnmarshalBinary(b []byte) error { - var res APIParameter - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline.go deleted file mode 100644 index ba9aa33bb04..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline.go +++ /dev/null @@ -1,116 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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" - "github.com/go-openapi/validate" -) - -// APIPipeline api pipeline -// swagger:model apiPipeline -type APIPipeline struct { - - // created at - // Format: date-time - CreatedAt strfmt.DateTime `json:"created_at,omitempty"` - - // description - Description string `json:"description,omitempty"` - - // In case any error happens retrieving a pipeline field, only pipeline ID - // and the error message is returned. Client has the flexibility of choosing - // how to handle error. This is especially useful during listing call. - Error string `json:"error,omitempty"` - - // id - ID string `json:"id,omitempty"` - - // name - Name string `json:"name,omitempty"` - - // parameters - Parameters []*APIParameter `json:"parameters"` -} - -// Validate validates this api pipeline -func (m *APIPipeline) Validate(formats strfmt.Registry) error { - var res []error - - if err := m.validateCreatedAt(formats); err != nil { - res = append(res, err) - } - - if err := m.validateParameters(formats); err != nil { - res = append(res, err) - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} - -func (m *APIPipeline) validateCreatedAt(formats strfmt.Registry) error { - - if swag.IsZero(m.CreatedAt) { // not required - return nil - } - - if err := validate.FormatOf("created_at", "body", "date-time", m.CreatedAt.String(), formats); err != nil { - return err - } - - return nil -} - -func (m *APIPipeline) validateParameters(formats strfmt.Registry) error { - - if swag.IsZero(m.Parameters) { // not required - return nil - } - - for i := 0; i < len(m.Parameters); i++ { - if swag.IsZero(m.Parameters[i]) { // not required - continue - } - - if m.Parameters[i] != nil { - if err := m.Parameters[i].Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("parameters" + "." + strconv.Itoa(i)) - } - return err - } - } - - } - - return nil -} - -// MarshalBinary interface implementation -func (m *APIPipeline) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIPipeline) UnmarshalBinary(b []byte) error { - var res APIPipeline - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline_version.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline_version.go deleted file mode 100644 index 1d6f169f7f0..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_pipeline_version.go +++ /dev/null @@ -1,171 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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" - "github.com/go-openapi/validate" -) - -// APIPipelineVersion api pipeline version -// swagger:model apiPipelineVersion -type APIPipelineVersion struct { - - // Input. Optional. Pipeline version code source. - CodeSourceURL string `json:"code_source_url,omitempty"` - - // Output. The time this pipeline version is created. - // Format: date-time - CreatedAt strfmt.DateTime `json:"created_at,omitempty"` - - // Output. Unique version ID. Generated by API server. - ID string `json:"id,omitempty"` - - // Optional input field. Version name provided by user. - Name string `json:"name,omitempty"` - - // Input. Required. Pipeline version package url. - // Whe calling CreatePipelineVersion API method, need to provide one package - // file location. - PackageURL *APIURL `json:"package_url,omitempty"` - - // Output. The input parameters for this pipeline. - Parameters []*APIParameter `json:"parameters"` - - // Input. Required. E.g., specify which pipeline this pipeline version belongs - // to. - ResourceReferences []*APIResourceReference `json:"resource_references"` -} - -// Validate validates this api pipeline version -func (m *APIPipelineVersion) Validate(formats strfmt.Registry) error { - var res []error - - if err := m.validateCreatedAt(formats); err != nil { - res = append(res, err) - } - - if err := m.validatePackageURL(formats); err != nil { - res = append(res, err) - } - - if err := m.validateParameters(formats); err != nil { - res = append(res, err) - } - - if err := m.validateResourceReferences(formats); err != nil { - res = append(res, err) - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} - -func (m *APIPipelineVersion) validateCreatedAt(formats strfmt.Registry) error { - - if swag.IsZero(m.CreatedAt) { // not required - return nil - } - - if err := validate.FormatOf("created_at", "body", "date-time", m.CreatedAt.String(), formats); err != nil { - return err - } - - return nil -} - -func (m *APIPipelineVersion) validatePackageURL(formats strfmt.Registry) error { - - if swag.IsZero(m.PackageURL) { // not required - return nil - } - - if m.PackageURL != nil { - if err := m.PackageURL.Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("package_url") - } - return err - } - } - - return nil -} - -func (m *APIPipelineVersion) validateParameters(formats strfmt.Registry) error { - - if swag.IsZero(m.Parameters) { // not required - return nil - } - - for i := 0; i < len(m.Parameters); i++ { - if swag.IsZero(m.Parameters[i]) { // not required - continue - } - - if m.Parameters[i] != nil { - if err := m.Parameters[i].Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("parameters" + "." + strconv.Itoa(i)) - } - return err - } - } - - } - - return nil -} - -func (m *APIPipelineVersion) validateResourceReferences(formats strfmt.Registry) error { - - if swag.IsZero(m.ResourceReferences) { // not required - return nil - } - - for i := 0; i < len(m.ResourceReferences); i++ { - if swag.IsZero(m.ResourceReferences[i]) { // not required - continue - } - - if m.ResourceReferences[i] != nil { - if err := m.ResourceReferences[i].Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("resource_references" + "." + strconv.Itoa(i)) - } - return err - } - } - - } - - return nil -} - -// MarshalBinary interface implementation -func (m *APIPipelineVersion) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIPipelineVersion) UnmarshalBinary(b []byte) error { - var res APIPipelineVersion - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_relationship.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_relationship.go deleted file mode 100644 index b4f85b6da9a..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_relationship.go +++ /dev/null @@ -1,66 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_model - -// This file was generated by the swagger tool. -// Editing this file might prove futile when you re-run the swagger generate command - -import ( - "encoding/json" - - strfmt "github.com/go-openapi/strfmt" - - "github.com/go-openapi/errors" - "github.com/go-openapi/validate" -) - -// APIRelationship api relationship -// swagger:model apiRelationship -type APIRelationship string - -const ( - - // APIRelationshipUNKNOWNRELATIONSHIP captures enum value "UNKNOWN_RELATIONSHIP" - APIRelationshipUNKNOWNRELATIONSHIP APIRelationship = "UNKNOWN_RELATIONSHIP" - - // APIRelationshipOWNER captures enum value "OWNER" - APIRelationshipOWNER APIRelationship = "OWNER" - - // APIRelationshipCREATOR captures enum value "CREATOR" - APIRelationshipCREATOR APIRelationship = "CREATOR" -) - -// for schema -var apiRelationshipEnum []interface{} - -func init() { - var res []APIRelationship - if err := json.Unmarshal([]byte(`["UNKNOWN_RELATIONSHIP","OWNER","CREATOR"]`), &res); err != nil { - panic(err) - } - for _, v := range res { - apiRelationshipEnum = append(apiRelationshipEnum, v) - } -} - -func (m APIRelationship) validateAPIRelationshipEnum(path, location string, value APIRelationship) error { - if err := validate.Enum(path, location, value, apiRelationshipEnum); err != nil { - return err - } - return nil -} - -// Validate validates this api relationship -func (m APIRelationship) Validate(formats strfmt.Registry) error { - var res []error - - // value enum - if err := m.validateAPIRelationshipEnum("", "body", m); err != nil { - return err - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_key.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_key.go deleted file mode 100644 index 2242421be03..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_key.go +++ /dev/null @@ -1,72 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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" -) - -// APIResourceKey api resource key -// swagger:model apiResourceKey -type APIResourceKey struct { - - // The ID of the resource that referred to. - ID string `json:"id,omitempty"` - - // The type of the resource that referred to. - Type APIResourceType `json:"type,omitempty"` -} - -// Validate validates this api resource key -func (m *APIResourceKey) Validate(formats strfmt.Registry) error { - var res []error - - if err := m.validateType(formats); err != nil { - res = append(res, err) - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} - -func (m *APIResourceKey) validateType(formats strfmt.Registry) error { - - if swag.IsZero(m.Type) { // not required - return nil - } - - if err := m.Type.Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("type") - } - return err - } - - return nil -} - -// MarshalBinary interface implementation -func (m *APIResourceKey) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIResourceKey) UnmarshalBinary(b []byte) error { - var res APIResourceKey - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_reference.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_reference.go deleted file mode 100644 index c5fcfce9441..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_reference.go +++ /dev/null @@ -1,97 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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" -) - -// APIResourceReference api resource reference -// swagger:model apiResourceReference -type APIResourceReference struct { - - // key - Key *APIResourceKey `json:"key,omitempty"` - - // The name of the resource that referred to. - Name string `json:"name,omitempty"` - - // Required field. The relationship from referred resource to the object. - Relationship APIRelationship `json:"relationship,omitempty"` -} - -// Validate validates this api resource reference -func (m *APIResourceReference) Validate(formats strfmt.Registry) error { - var res []error - - if err := m.validateKey(formats); err != nil { - res = append(res, err) - } - - if err := m.validateRelationship(formats); err != nil { - res = append(res, err) - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} - -func (m *APIResourceReference) validateKey(formats strfmt.Registry) error { - - if swag.IsZero(m.Key) { // not required - return nil - } - - if m.Key != nil { - if err := m.Key.Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("key") - } - return err - } - } - - return nil -} - -func (m *APIResourceReference) validateRelationship(formats strfmt.Registry) error { - - if swag.IsZero(m.Relationship) { // not required - return nil - } - - if err := m.Relationship.Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("relationship") - } - return err - } - - return nil -} - -// MarshalBinary interface implementation -func (m *APIResourceReference) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIResourceReference) UnmarshalBinary(b []byte) error { - var res APIResourceReference - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_type.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_type.go deleted file mode 100644 index b0fe8702d6e..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_resource_type.go +++ /dev/null @@ -1,75 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_model - -// This file was generated by the swagger tool. -// Editing this file might prove futile when you re-run the swagger generate command - -import ( - "encoding/json" - - strfmt "github.com/go-openapi/strfmt" - - "github.com/go-openapi/errors" - "github.com/go-openapi/validate" -) - -// APIResourceType api resource type -// swagger:model apiResourceType -type APIResourceType string - -const ( - - // APIResourceTypeUNKNOWNRESOURCETYPE captures enum value "UNKNOWN_RESOURCE_TYPE" - APIResourceTypeUNKNOWNRESOURCETYPE APIResourceType = "UNKNOWN_RESOURCE_TYPE" - - // APIResourceTypeEXPERIMENT captures enum value "EXPERIMENT" - APIResourceTypeEXPERIMENT APIResourceType = "EXPERIMENT" - - // APIResourceTypeJOB captures enum value "JOB" - APIResourceTypeJOB APIResourceType = "JOB" - - // APIResourceTypePIPELINE captures enum value "PIPELINE" - APIResourceTypePIPELINE APIResourceType = "PIPELINE" - - // APIResourceTypePIPELINEVERSION captures enum value "PIPELINE_VERSION" - APIResourceTypePIPELINEVERSION APIResourceType = "PIPELINE_VERSION" - - // APIResourceTypeNAMESPACE captures enum value "NAMESPACE" - APIResourceTypeNAMESPACE APIResourceType = "NAMESPACE" -) - -// for schema -var apiResourceTypeEnum []interface{} - -func init() { - var res []APIResourceType - if err := json.Unmarshal([]byte(`["UNKNOWN_RESOURCE_TYPE","EXPERIMENT","JOB","PIPELINE","PIPELINE_VERSION","NAMESPACE"]`), &res); err != nil { - panic(err) - } - for _, v := range res { - apiResourceTypeEnum = append(apiResourceTypeEnum, v) - } -} - -func (m APIResourceType) validateAPIResourceTypeEnum(path, location string, value APIResourceType) error { - if err := validate.Enum(path, location, value, apiResourceTypeEnum); err != nil { - return err - } - return nil -} - -// Validate validates this api resource type -func (m APIResourceType) Validate(formats strfmt.Registry) error { - var res []error - - // value enum - if err := m.validateAPIResourceTypeEnum("", "body", m); err != nil { - return err - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_status.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_status.go deleted file mode 100644 index a1df8518689..00000000000 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_status.go +++ /dev/null @@ -1,86 +0,0 @@ -// Code generated by go-swagger; DO NOT EDIT. - -package pipeline_upload_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" -) - -// APIStatus api status -// swagger:model apiStatus -type APIStatus struct { - - // code - Code int32 `json:"code,omitempty"` - - // details - Details []*ProtobufAny `json:"details"` - - // error - Error string `json:"error,omitempty"` -} - -// Validate validates this api status -func (m *APIStatus) Validate(formats strfmt.Registry) error { - var res []error - - if err := m.validateDetails(formats); err != nil { - res = append(res, err) - } - - if len(res) > 0 { - return errors.CompositeValidationError(res...) - } - return nil -} - -func (m *APIStatus) validateDetails(formats strfmt.Registry) error { - - if swag.IsZero(m.Details) { // not required - return nil - } - - for i := 0; i < len(m.Details); i++ { - if swag.IsZero(m.Details[i]) { // not required - continue - } - - if m.Details[i] != nil { - if err := m.Details[i].Validate(formats); err != nil { - if ve, ok := err.(*errors.Validation); ok { - return ve.ValidateName("details" + "." + strconv.Itoa(i)) - } - return err - } - } - - } - - return nil -} - -// MarshalBinary interface implementation -func (m *APIStatus) MarshalBinary() ([]byte, error) { - if m == nil { - return nil, nil - } - return swag.WriteJSON(m) -} - -// UnmarshalBinary interface implementation -func (m *APIStatus) UnmarshalBinary(b []byte) error { - var res APIStatus - if err := swag.ReadJSON(b, &res); err != nil { - return err - } - *m = res - return nil -} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/googlerpc_status.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/googlerpc_status.go new file mode 100644 index 00000000000..15fca7b664b --- /dev/null +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_model/googlerpc_status.go @@ -0,0 +1,95 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package pipeline_upload_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" +) + +// GooglerpcStatus The `Status` type defines a logical error model that is suitable for +// different programming environments, including REST APIs and RPC APIs. It is +// used by [gRPC](https://github.com/grpc). Each `Status` message contains +// three pieces of data: error code, error message, and error details. +// +// You can find out more about this error model and how to work with it in the +// [API Design Guide](https://cloud.google.com/apis/design/errors). +// swagger:model googlerpcStatus +type GooglerpcStatus struct { + + // The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code]. + Code int32 `json:"code,omitempty"` + + // A list of messages that carry the error details. There is a common set of + // message types for APIs to use. + Details []*ProtobufAny `json:"details"` + + // A developer-facing error message, which should be in English. Any + // user-facing error message should be localized and sent in the + // [google.rpc.Status.details][google.rpc.Status.details] field, or localized by the client. + Message string `json:"message,omitempty"` +} + +// Validate validates this googlerpc status +func (m *GooglerpcStatus) Validate(formats strfmt.Registry) error { + var res []error + + if err := m.validateDetails(formats); err != nil { + res = append(res, err) + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} + +func (m *GooglerpcStatus) validateDetails(formats strfmt.Registry) error { + + if swag.IsZero(m.Details) { // not required + return nil + } + + for i := 0; i < len(m.Details); i++ { + if swag.IsZero(m.Details[i]) { // not required + continue + } + + if m.Details[i] != nil { + if err := m.Details[i].Validate(formats); err != nil { + if ve, ok := err.(*errors.Validation); ok { + return ve.ValidateName("details" + "." + strconv.Itoa(i)) + } + return err + } + } + + } + + return nil +} + +// MarshalBinary interface implementation +func (m *GooglerpcStatus) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *GooglerpcStatus) UnmarshalBinary(b []byte) error { + var res GooglerpcStatus + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline.go new file mode 100644 index 00000000000..1204a78e7be --- /dev/null +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline.go @@ -0,0 +1,109 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package pipeline_upload_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" +) + +// V2beta1Pipeline v2beta1 pipeline +// swagger:model v2beta1Pipeline +type V2beta1Pipeline struct { + + // Output. Creation time of the pipeline. + // Format: date-time + CreatedAt strfmt.DateTime `json:"created_at,omitempty"` + + // Optional input field. A short description of the pipeline. + Description string `json:"description,omitempty"` + + // Required input field. Pipeline name provided by user. + DisplayName string `json:"display_name,omitempty"` + + // In case any error happens retrieving a pipeline field, only pipeline ID, + // and the error message is returned. Client has the flexibility of choosing + // how to handle the error. This is especially useful during listing call. + Error *GooglerpcStatus `json:"error,omitempty"` + + // Input. A namespace this pipeline belongs to. + // Causes error if user is not authorized to access the specified namespace. + // If not specified in CreatePipeline, default namespace is used. + Namespace string `json:"namespace,omitempty"` + + // Output. Unique pipeline ID. Generated by API server. + PipelineID string `json:"pipeline_id,omitempty"` +} + +// Validate validates this v2beta1 pipeline +func (m *V2beta1Pipeline) Validate(formats strfmt.Registry) error { + var res []error + + if err := m.validateCreatedAt(formats); err != nil { + res = append(res, err) + } + + if err := m.validateError(formats); err != nil { + res = append(res, err) + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} + +func (m *V2beta1Pipeline) validateCreatedAt(formats strfmt.Registry) error { + + if swag.IsZero(m.CreatedAt) { // not required + return nil + } + + if err := validate.FormatOf("created_at", "body", "date-time", m.CreatedAt.String(), formats); err != nil { + return err + } + + return nil +} + +func (m *V2beta1Pipeline) validateError(formats strfmt.Registry) error { + + if swag.IsZero(m.Error) { // not required + return nil + } + + if m.Error != nil { + if err := m.Error.Validate(formats); err != nil { + if ve, ok := err.(*errors.Validation); ok { + return ve.ValidateName("error") + } + return err + } + } + + return nil +} + +// MarshalBinary interface implementation +func (m *V2beta1Pipeline) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *V2beta1Pipeline) UnmarshalBinary(b []byte) error { + var res V2beta1Pipeline + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline_version.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline_version.go new file mode 100644 index 00000000000..c3d26ee9345 --- /dev/null +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_pipeline_version.go @@ -0,0 +1,144 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package pipeline_upload_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" +) + +// V2beta1PipelineVersion v2beta1 pipeline version +// swagger:model v2beta1PipelineVersion +type V2beta1PipelineVersion struct { + + // Input. Optional. The URL to the code source of the pipeline version. + // The code is usually the Python definition of the pipeline and potentially + // related the component definitions. This allows users to trace back to how + // the pipeline YAML was created. + CodeSourceURL string `json:"code_source_url,omitempty"` + + // Output. Creation time of the pipeline version. + // Format: date-time + CreatedAt strfmt.DateTime `json:"created_at,omitempty"` + + // Optional input field. Short description of the pipeline version. + Description string `json:"description,omitempty"` + + // Required input field. Pipeline version name provided by user. + DisplayName string `json:"display_name,omitempty"` + + // In case any error happens retrieving a pipeline version field, only + // pipeline ID, pipeline version ID, and the error message are returned. + // Client has the flexibility of choosing how to handle the error. + // This is especially useful during List() calls. + Error *GooglerpcStatus `json:"error,omitempty"` + + // Input. Required. The URL to the source of the pipeline version. + // This is required when creating the pipeine version through + // CreatePipelineVersion API. + PackageURL *V2beta1URL `json:"package_url,omitempty"` + + // Required input field. Unique ID of the parent pipeline. + PipelineID string `json:"pipeline_id,omitempty"` + + // Output. The pipeline spec for the pipeline version. + PipelineSpec interface{} `json:"pipeline_spec,omitempty"` + + // Output. Unique pipeline version ID. Generated by API server. + PipelineVersionID string `json:"pipeline_version_id,omitempty"` +} + +// Validate validates this v2beta1 pipeline version +func (m *V2beta1PipelineVersion) Validate(formats strfmt.Registry) error { + var res []error + + if err := m.validateCreatedAt(formats); err != nil { + res = append(res, err) + } + + if err := m.validateError(formats); err != nil { + res = append(res, err) + } + + if err := m.validatePackageURL(formats); err != nil { + res = append(res, err) + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} + +func (m *V2beta1PipelineVersion) validateCreatedAt(formats strfmt.Registry) error { + + if swag.IsZero(m.CreatedAt) { // not required + return nil + } + + if err := validate.FormatOf("created_at", "body", "date-time", m.CreatedAt.String(), formats); err != nil { + return err + } + + return nil +} + +func (m *V2beta1PipelineVersion) validateError(formats strfmt.Registry) error { + + if swag.IsZero(m.Error) { // not required + return nil + } + + if m.Error != nil { + if err := m.Error.Validate(formats); err != nil { + if ve, ok := err.(*errors.Validation); ok { + return ve.ValidateName("error") + } + return err + } + } + + return nil +} + +func (m *V2beta1PipelineVersion) validatePackageURL(formats strfmt.Registry) error { + + if swag.IsZero(m.PackageURL) { // not required + return nil + } + + if m.PackageURL != nil { + if err := m.PackageURL.Validate(formats); err != nil { + if ve, ok := err.(*errors.Validation); ok { + return ve.ValidateName("package_url") + } + return err + } + } + + return nil +} + +// MarshalBinary interface implementation +func (m *V2beta1PipelineVersion) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *V2beta1PipelineVersion) UnmarshalBinary(b []byte) error { + var res V2beta1PipelineVersion + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_url.go b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_url.go similarity index 62% rename from backend/api/v2beta1/go_http_client/pipeline_upload_model/api_url.go rename to backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_url.go index b1ebfac3c25..0a8ea1c8758 100644 --- a/backend/api/v2beta1/go_http_client/pipeline_upload_model/api_url.go +++ b/backend/api/v2beta1/go_http_client/pipeline_upload_model/v2beta1_url.go @@ -11,21 +11,21 @@ import ( "github.com/go-openapi/swag" ) -// APIURL api Url -// swagger:model apiUrl -type APIURL struct { +// V2beta1URL v2beta1 Url +// swagger:model v2beta1Url +type V2beta1URL struct { - // pipeline url + // URL of the pipeline version definition. PipelineURL string `json:"pipeline_url,omitempty"` } -// Validate validates this api Url -func (m *APIURL) Validate(formats strfmt.Registry) error { +// Validate validates this v2beta1 Url +func (m *V2beta1URL) Validate(formats strfmt.Registry) error { return nil } // MarshalBinary interface implementation -func (m *APIURL) MarshalBinary() ([]byte, error) { +func (m *V2beta1URL) MarshalBinary() ([]byte, error) { if m == nil { return nil, nil } @@ -33,8 +33,8 @@ func (m *APIURL) MarshalBinary() ([]byte, error) { } // UnmarshalBinary interface implementation -func (m *APIURL) UnmarshalBinary(b []byte) error { - var res APIURL +func (m *V2beta1URL) UnmarshalBinary(b []byte) error { + var res V2beta1URL if err := swag.ReadJSON(b, &res); err != nil { return err } diff --git a/backend/api/v2beta1/python_http_client/README.md b/backend/api/v2beta1/python_http_client/README.md index 45574eebbf5..d0b124e4992 100644 --- a/backend/api/v2beta1/python_http_client/README.md +++ b/backend/api/v2beta1/python_http_client/README.md @@ -138,15 +138,6 @@ Class | Method | HTTP request | Description ## Documentation For Models - - [ApiParameter](docs/ApiParameter.md) - - [ApiPipeline](docs/ApiPipeline.md) - - [ApiPipelineVersion](docs/ApiPipelineVersion.md) - - [ApiRelationship](docs/ApiRelationship.md) - - [ApiResourceKey](docs/ApiResourceKey.md) - - [ApiResourceReference](docs/ApiResourceReference.md) - - [ApiResourceType](docs/ApiResourceType.md) - - [ApiStatus](docs/ApiStatus.md) - - [ApiUrl](docs/ApiUrl.md) - [AuthorizeRequestResources](docs/AuthorizeRequestResources.md) - [AuthorizeRequestVerb](docs/AuthorizeRequestVerb.md) - [GooglerpcStatus](docs/GooglerpcStatus.md) diff --git a/backend/api/v2beta1/python_http_client/docs/ApiParameter.md b/backend/api/v2beta1/python_http_client/docs/ApiParameter.md deleted file mode 100644 index c13ddecead6..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiParameter.md +++ /dev/null @@ -1,11 +0,0 @@ -# ApiParameter - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**name** | **str** | | [optional] -**value** | **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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiPipeline.md b/backend/api/v2beta1/python_http_client/docs/ApiPipeline.md deleted file mode 100644 index fad2066adcb..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiPipeline.md +++ /dev/null @@ -1,15 +0,0 @@ -# ApiPipeline - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**id** | **str** | | [optional] -**created_at** | **datetime** | | [optional] -**name** | **str** | | [optional] -**description** | **str** | | [optional] -**parameters** | [**list[ApiParameter]**](ApiParameter.md) | | [optional] -**error** | **str** | In case any error happens retrieving a pipeline field, only pipeline ID and the error message is returned. Client has the flexibility of choosing how to handle error. This is especially useful during listing call. | [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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiPipelineVersion.md b/backend/api/v2beta1/python_http_client/docs/ApiPipelineVersion.md deleted file mode 100644 index fea8886aad8..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiPipelineVersion.md +++ /dev/null @@ -1,16 +0,0 @@ -# ApiPipelineVersion - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**id** | **str** | Output. Unique version ID. Generated by API server. | [optional] -**name** | **str** | Optional input field. Version name provided by user. | [optional] -**created_at** | **datetime** | Output. The time this pipeline version is created. | [optional] -**parameters** | [**list[ApiParameter]**](ApiParameter.md) | Output. The input parameters for this pipeline. | [optional] -**code_source_url** | **str** | Input. Optional. Pipeline version code source. | [optional] -**package_url** | [**ApiUrl**](ApiUrl.md) | | [optional] -**resource_references** | [**list[ApiResourceReference]**](ApiResourceReference.md) | Input. Required. E.g., specify which pipeline this pipeline version belongs to. | [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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiRelationship.md b/backend/api/v2beta1/python_http_client/docs/ApiRelationship.md deleted file mode 100644 index 3e6ef677702..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiRelationship.md +++ /dev/null @@ -1,9 +0,0 @@ -# ApiRelationship - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- - -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiResourceKey.md b/backend/api/v2beta1/python_http_client/docs/ApiResourceKey.md deleted file mode 100644 index f9ea3dd7b48..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiResourceKey.md +++ /dev/null @@ -1,11 +0,0 @@ -# ApiResourceKey - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**type** | [**ApiResourceType**](ApiResourceType.md) | | [optional] -**id** | **str** | The ID of the resource that referred to. | [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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiResourceReference.md b/backend/api/v2beta1/python_http_client/docs/ApiResourceReference.md deleted file mode 100644 index acbb24ed2dd..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiResourceReference.md +++ /dev/null @@ -1,12 +0,0 @@ -# ApiResourceReference - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**key** | [**ApiResourceKey**](ApiResourceKey.md) | | [optional] -**name** | **str** | The name of the resource that referred to. | [optional] -**relationship** | [**ApiRelationship**](ApiRelationship.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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiResourceType.md b/backend/api/v2beta1/python_http_client/docs/ApiResourceType.md deleted file mode 100644 index 0d3f7688726..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiResourceType.md +++ /dev/null @@ -1,9 +0,0 @@ -# ApiResourceType - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- - -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiStatus.md b/backend/api/v2beta1/python_http_client/docs/ApiStatus.md deleted file mode 100644 index 6a3feb57f30..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiStatus.md +++ /dev/null @@ -1,12 +0,0 @@ -# ApiStatus - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**error** | **str** | | [optional] -**code** | **int** | | [optional] -**details** | [**list[ProtobufAny]**](ProtobufAny.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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/ApiUrl.md b/backend/api/v2beta1/python_http_client/docs/ApiUrl.md deleted file mode 100644 index a098f68fba5..00000000000 --- a/backend/api/v2beta1/python_http_client/docs/ApiUrl.md +++ /dev/null @@ -1,10 +0,0 @@ -# ApiUrl - -## Properties -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**pipeline_url** | **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) - - diff --git a/backend/api/v2beta1/python_http_client/docs/PipelineUploadServiceApi.md b/backend/api/v2beta1/python_http_client/docs/PipelineUploadServiceApi.md index c24bc981447..d38a51ae3b3 100644 --- a/backend/api/v2beta1/python_http_client/docs/PipelineUploadServiceApi.md +++ b/backend/api/v2beta1/python_http_client/docs/PipelineUploadServiceApi.md @@ -9,7 +9,7 @@ Method | HTTP request | Description # **upload_pipeline** -> ApiPipeline upload_pipeline(uploadfile, name=name, description=description, namespace=namespace) +> V2beta1Pipeline upload_pipeline(uploadfile, name=name, description=description, namespace=namespace) @@ -70,7 +70,7 @@ Name | Type | Description | Notes ### Return type -[**ApiPipeline**](ApiPipeline.md) +[**V2beta1Pipeline**](V2beta1Pipeline.md) ### Authorization @@ -90,7 +90,7 @@ Name | Type | Description | Notes [[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md) # **upload_pipeline_version** -> ApiPipelineVersion upload_pipeline_version(uploadfile, name=name, pipelineid=pipelineid, description=description, namespace=namespace) +> V2beta1PipelineVersion upload_pipeline_version(uploadfile, name=name, pipelineid=pipelineid, description=description) @@ -132,10 +132,9 @@ with kfp_server_api.ApiClient(configuration) as api_client: name = 'name_example' # str | (optional) pipelineid = 'pipelineid_example' # str | (optional) description = 'description_example' # str | (optional) -namespace = 'namespace_example' # str | (optional) try: - api_response = api_instance.upload_pipeline_version(uploadfile, name=name, pipelineid=pipelineid, description=description, namespace=namespace) + api_response = api_instance.upload_pipeline_version(uploadfile, name=name, pipelineid=pipelineid, description=description) pprint(api_response) except ApiException as e: print("Exception when calling PipelineUploadServiceApi->upload_pipeline_version: %s\n" % e) @@ -149,11 +148,10 @@ Name | Type | Description | Notes **name** | **str**| | [optional] **pipelineid** | **str**| | [optional] **description** | **str**| | [optional] - **namespace** | **str**| | [optional] ### Return type -[**ApiPipelineVersion**](ApiPipelineVersion.md) +[**V2beta1PipelineVersion**](V2beta1PipelineVersion.md) ### Authorization diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py b/backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py index f6299a05580..2b8ea47cb0d 100644 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py +++ b/backend/api/v2beta1/python_http_client/kfp_server_api/__init__.py @@ -36,15 +36,6 @@ from kfp_server_api.exceptions import ApiKeyError from kfp_server_api.exceptions import ApiException # import models into sdk package -from kfp_server_api.models.api_parameter import ApiParameter -from kfp_server_api.models.api_pipeline import ApiPipeline -from kfp_server_api.models.api_pipeline_version import ApiPipelineVersion -from kfp_server_api.models.api_relationship import ApiRelationship -from kfp_server_api.models.api_resource_key import ApiResourceKey -from kfp_server_api.models.api_resource_reference import ApiResourceReference -from kfp_server_api.models.api_resource_type import ApiResourceType -from kfp_server_api.models.api_status import ApiStatus -from kfp_server_api.models.api_url import ApiUrl from kfp_server_api.models.authorize_request_resources import AuthorizeRequestResources from kfp_server_api.models.authorize_request_verb import AuthorizeRequestVerb from kfp_server_api.models.googlerpc_status import GooglerpcStatus diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/api/pipeline_upload_service_api.py b/backend/api/v2beta1/python_http_client/kfp_server_api/api/pipeline_upload_service_api.py index 83c6503162d..92ffc8ccc1f 100644 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/api/pipeline_upload_service_api.py +++ b/backend/api/v2beta1/python_http_client/kfp_server_api/api/pipeline_upload_service_api.py @@ -65,7 +65,7 @@ def upload_pipeline(self, uploadfile, **kwargs): # noqa: E501 :return: Returns the result object. If the method is called asynchronously, returns the request thread. - :rtype: ApiPipeline + :rtype: V2beta1Pipeline """ kwargs['_return_http_data_only'] = True return self.upload_pipeline_with_http_info(uploadfile, **kwargs) # noqa: E501 @@ -103,7 +103,7 @@ def upload_pipeline_with_http_info(self, uploadfile, **kwargs): # noqa: E501 :return: Returns the result object. If the method is called asynchronously, returns the request thread. - :rtype: tuple(ApiPipeline, status_code(int), headers(HTTPHeaderDict)) + :rtype: tuple(V2beta1Pipeline, status_code(int), headers(HTTPHeaderDict)) """ local_var_params = locals() @@ -175,7 +175,7 @@ def upload_pipeline_with_http_info(self, uploadfile, **kwargs): # noqa: E501 body=body_params, post_params=form_params, files=local_var_files, - response_type='ApiPipeline', # noqa: E501 + response_type='V2beta1Pipeline', # noqa: E501 auth_settings=auth_settings, async_req=local_var_params.get('async_req'), _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 @@ -200,8 +200,6 @@ def upload_pipeline_version(self, uploadfile, **kwargs): # noqa: E501 :type pipelineid: str :param description: :type description: str - :param namespace: - :type namespace: str :param async_req: Whether to execute the request asynchronously. :type async_req: bool, optional :param _preload_content: if False, the urllib3.HTTPResponse object will @@ -214,7 +212,7 @@ def upload_pipeline_version(self, uploadfile, **kwargs): # noqa: E501 :return: Returns the result object. If the method is called asynchronously, returns the request thread. - :rtype: ApiPipelineVersion + :rtype: V2beta1PipelineVersion """ kwargs['_return_http_data_only'] = True return self.upload_pipeline_version_with_http_info(uploadfile, **kwargs) # noqa: E501 @@ -236,8 +234,6 @@ def upload_pipeline_version_with_http_info(self, uploadfile, **kwargs): # noqa: :type pipelineid: str :param description: :type description: str - :param namespace: - :type namespace: str :param async_req: Whether to execute the request asynchronously. :type async_req: bool, optional :param _return_http_data_only: response data without head status code @@ -254,7 +250,7 @@ def upload_pipeline_version_with_http_info(self, uploadfile, **kwargs): # noqa: :return: Returns the result object. If the method is called asynchronously, returns the request thread. - :rtype: tuple(ApiPipelineVersion, status_code(int), headers(HTTPHeaderDict)) + :rtype: tuple(V2beta1PipelineVersion, status_code(int), headers(HTTPHeaderDict)) """ local_var_params = locals() @@ -263,8 +259,7 @@ def upload_pipeline_version_with_http_info(self, uploadfile, **kwargs): # noqa: 'uploadfile', 'name', 'pipelineid', - 'description', - 'namespace' + 'description' ] all_params.extend( [ @@ -299,8 +294,6 @@ def upload_pipeline_version_with_http_info(self, uploadfile, **kwargs): # noqa: query_params.append(('pipelineid', local_var_params['pipelineid'])) # noqa: E501 if 'description' in local_var_params and local_var_params['description'] is not None: # noqa: E501 query_params.append(('description', local_var_params['description'])) # noqa: E501 - if 'namespace' in local_var_params and local_var_params['namespace'] is not None: # noqa: E501 - query_params.append(('namespace', local_var_params['namespace'])) # noqa: E501 header_params = {} @@ -329,7 +322,7 @@ def upload_pipeline_version_with_http_info(self, uploadfile, **kwargs): # noqa: body=body_params, post_params=form_params, files=local_var_files, - response_type='ApiPipelineVersion', # noqa: E501 + response_type='V2beta1PipelineVersion', # noqa: E501 auth_settings=auth_settings, async_req=local_var_params.get('async_req'), _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py index 38c9397ee94..257818252f8 100644 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py +++ b/backend/api/v2beta1/python_http_client/kfp_server_api/models/__init__.py @@ -14,15 +14,6 @@ from __future__ import absolute_import # import models into model package -from kfp_server_api.models.api_parameter import ApiParameter -from kfp_server_api.models.api_pipeline import ApiPipeline -from kfp_server_api.models.api_pipeline_version import ApiPipelineVersion -from kfp_server_api.models.api_relationship import ApiRelationship -from kfp_server_api.models.api_resource_key import ApiResourceKey -from kfp_server_api.models.api_resource_reference import ApiResourceReference -from kfp_server_api.models.api_resource_type import ApiResourceType -from kfp_server_api.models.api_status import ApiStatus -from kfp_server_api.models.api_url import ApiUrl from kfp_server_api.models.authorize_request_resources import AuthorizeRequestResources from kfp_server_api.models.authorize_request_verb import AuthorizeRequestVerb from kfp_server_api.models.googlerpc_status import GooglerpcStatus diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_parameter.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_parameter.py deleted file mode 100644 index 0621a88bc00..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_parameter.py +++ /dev/null @@ -1,146 +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 ApiParameter(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 = { - 'name': 'str', - 'value': 'str' - } - - attribute_map = { - 'name': 'name', - 'value': 'value' - } - - def __init__(self, name=None, value=None, local_vars_configuration=None): # noqa: E501 - """ApiParameter - 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._name = None - self._value = None - self.discriminator = None - - if name is not None: - self.name = name - if value is not None: - self.value = value - - @property - def name(self): - """Gets the name of this ApiParameter. # noqa: E501 - - - :return: The name of this ApiParameter. # noqa: E501 - :rtype: str - """ - return self._name - - @name.setter - def name(self, name): - """Sets the name of this ApiParameter. - - - :param name: The name of this ApiParameter. # noqa: E501 - :type name: str - """ - - self._name = name - - @property - def value(self): - """Gets the value of this ApiParameter. # noqa: E501 - - - :return: The value of this ApiParameter. # noqa: E501 - :rtype: str - """ - return self._value - - @value.setter - def value(self, value): - """Sets the value of this ApiParameter. - - - :param value: The value of this ApiParameter. # noqa: E501 - :type value: str - """ - - self._value = 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, ApiParameter): - 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, ApiParameter): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline.py deleted file mode 100644 index 4e0c48a0c22..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline.py +++ /dev/null @@ -1,252 +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 ApiPipeline(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 = { - 'id': 'str', - 'created_at': 'datetime', - 'name': 'str', - 'description': 'str', - 'parameters': 'list[ApiParameter]', - 'error': 'str' - } - - attribute_map = { - 'id': 'id', - 'created_at': 'created_at', - 'name': 'name', - 'description': 'description', - 'parameters': 'parameters', - 'error': 'error' - } - - def __init__(self, id=None, created_at=None, name=None, description=None, parameters=None, error=None, local_vars_configuration=None): # noqa: E501 - """ApiPipeline - 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._id = None - self._created_at = None - self._name = None - self._description = None - self._parameters = None - self._error = None - self.discriminator = None - - if id is not None: - self.id = id - if created_at is not None: - self.created_at = created_at - if name is not None: - self.name = name - if description is not None: - self.description = description - if parameters is not None: - self.parameters = parameters - if error is not None: - self.error = error - - @property - def id(self): - """Gets the id of this ApiPipeline. # noqa: E501 - - - :return: The id of this ApiPipeline. # noqa: E501 - :rtype: str - """ - return self._id - - @id.setter - def id(self, id): - """Sets the id of this ApiPipeline. - - - :param id: The id of this ApiPipeline. # noqa: E501 - :type id: str - """ - - self._id = id - - @property - def created_at(self): - """Gets the created_at of this ApiPipeline. # noqa: E501 - - - :return: The created_at of this ApiPipeline. # noqa: E501 - :rtype: datetime - """ - return self._created_at - - @created_at.setter - def created_at(self, created_at): - """Sets the created_at of this ApiPipeline. - - - :param created_at: The created_at of this ApiPipeline. # noqa: E501 - :type created_at: datetime - """ - - self._created_at = created_at - - @property - def name(self): - """Gets the name of this ApiPipeline. # noqa: E501 - - - :return: The name of this ApiPipeline. # noqa: E501 - :rtype: str - """ - return self._name - - @name.setter - def name(self, name): - """Sets the name of this ApiPipeline. - - - :param name: The name of this ApiPipeline. # noqa: E501 - :type name: str - """ - - self._name = name - - @property - def description(self): - """Gets the description of this ApiPipeline. # noqa: E501 - - - :return: The description of this ApiPipeline. # noqa: E501 - :rtype: str - """ - return self._description - - @description.setter - def description(self, description): - """Sets the description of this ApiPipeline. - - - :param description: The description of this ApiPipeline. # noqa: E501 - :type description: str - """ - - self._description = description - - @property - def parameters(self): - """Gets the parameters of this ApiPipeline. # noqa: E501 - - - :return: The parameters of this ApiPipeline. # noqa: E501 - :rtype: list[ApiParameter] - """ - return self._parameters - - @parameters.setter - def parameters(self, parameters): - """Sets the parameters of this ApiPipeline. - - - :param parameters: The parameters of this ApiPipeline. # noqa: E501 - :type parameters: list[ApiParameter] - """ - - self._parameters = parameters - - @property - def error(self): - """Gets the error of this ApiPipeline. # noqa: E501 - - In case any error happens retrieving a pipeline field, only pipeline ID and the error message is returned. Client has the flexibility of choosing how to handle error. This is especially useful during listing call. # noqa: E501 - - :return: The error of this ApiPipeline. # noqa: E501 - :rtype: str - """ - return self._error - - @error.setter - def error(self, error): - """Sets the error of this ApiPipeline. - - In case any error happens retrieving a pipeline field, only pipeline ID and the error message is returned. Client has the flexibility of choosing how to handle error. This is especially useful during listing call. # noqa: E501 - - :param error: The error of this ApiPipeline. # noqa: E501 - :type error: str - """ - - self._error = error - - 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, ApiPipeline): - 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, ApiPipeline): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline_version.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline_version.py deleted file mode 100644 index 5208a5c91f9..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_pipeline_version.py +++ /dev/null @@ -1,288 +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 ApiPipelineVersion(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 = { - 'id': 'str', - 'name': 'str', - 'created_at': 'datetime', - 'parameters': 'list[ApiParameter]', - 'code_source_url': 'str', - 'package_url': 'ApiUrl', - 'resource_references': 'list[ApiResourceReference]' - } - - attribute_map = { - 'id': 'id', - 'name': 'name', - 'created_at': 'created_at', - 'parameters': 'parameters', - 'code_source_url': 'code_source_url', - 'package_url': 'package_url', - 'resource_references': 'resource_references' - } - - def __init__(self, id=None, name=None, created_at=None, parameters=None, code_source_url=None, package_url=None, resource_references=None, local_vars_configuration=None): # noqa: E501 - """ApiPipelineVersion - 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._id = None - self._name = None - self._created_at = None - self._parameters = None - self._code_source_url = None - self._package_url = None - self._resource_references = None - self.discriminator = None - - if id is not None: - self.id = id - if name is not None: - self.name = name - if created_at is not None: - self.created_at = created_at - if parameters is not None: - self.parameters = parameters - if code_source_url is not None: - self.code_source_url = code_source_url - if package_url is not None: - self.package_url = package_url - if resource_references is not None: - self.resource_references = resource_references - - @property - def id(self): - """Gets the id of this ApiPipelineVersion. # noqa: E501 - - Output. Unique version ID. Generated by API server. # noqa: E501 - - :return: The id of this ApiPipelineVersion. # noqa: E501 - :rtype: str - """ - return self._id - - @id.setter - def id(self, id): - """Sets the id of this ApiPipelineVersion. - - Output. Unique version ID. Generated by API server. # noqa: E501 - - :param id: The id of this ApiPipelineVersion. # noqa: E501 - :type id: str - """ - - self._id = id - - @property - def name(self): - """Gets the name of this ApiPipelineVersion. # noqa: E501 - - Optional input field. Version name provided by user. # noqa: E501 - - :return: The name of this ApiPipelineVersion. # noqa: E501 - :rtype: str - """ - return self._name - - @name.setter - def name(self, name): - """Sets the name of this ApiPipelineVersion. - - Optional input field. Version name provided by user. # noqa: E501 - - :param name: The name of this ApiPipelineVersion. # noqa: E501 - :type name: str - """ - - self._name = name - - @property - def created_at(self): - """Gets the created_at of this ApiPipelineVersion. # noqa: E501 - - Output. The time this pipeline version is created. # noqa: E501 - - :return: The created_at of this ApiPipelineVersion. # noqa: E501 - :rtype: datetime - """ - return self._created_at - - @created_at.setter - def created_at(self, created_at): - """Sets the created_at of this ApiPipelineVersion. - - Output. The time this pipeline version is created. # noqa: E501 - - :param created_at: The created_at of this ApiPipelineVersion. # noqa: E501 - :type created_at: datetime - """ - - self._created_at = created_at - - @property - def parameters(self): - """Gets the parameters of this ApiPipelineVersion. # noqa: E501 - - Output. The input parameters for this pipeline. # noqa: E501 - - :return: The parameters of this ApiPipelineVersion. # noqa: E501 - :rtype: list[ApiParameter] - """ - return self._parameters - - @parameters.setter - def parameters(self, parameters): - """Sets the parameters of this ApiPipelineVersion. - - Output. The input parameters for this pipeline. # noqa: E501 - - :param parameters: The parameters of this ApiPipelineVersion. # noqa: E501 - :type parameters: list[ApiParameter] - """ - - self._parameters = parameters - - @property - def code_source_url(self): - """Gets the code_source_url of this ApiPipelineVersion. # noqa: E501 - - Input. Optional. Pipeline version code source. # noqa: E501 - - :return: The code_source_url of this ApiPipelineVersion. # noqa: E501 - :rtype: str - """ - return self._code_source_url - - @code_source_url.setter - def code_source_url(self, code_source_url): - """Sets the code_source_url of this ApiPipelineVersion. - - Input. Optional. Pipeline version code source. # noqa: E501 - - :param code_source_url: The code_source_url of this ApiPipelineVersion. # noqa: E501 - :type code_source_url: str - """ - - self._code_source_url = code_source_url - - @property - def package_url(self): - """Gets the package_url of this ApiPipelineVersion. # noqa: E501 - - - :return: The package_url of this ApiPipelineVersion. # noqa: E501 - :rtype: ApiUrl - """ - return self._package_url - - @package_url.setter - def package_url(self, package_url): - """Sets the package_url of this ApiPipelineVersion. - - - :param package_url: The package_url of this ApiPipelineVersion. # noqa: E501 - :type package_url: ApiUrl - """ - - self._package_url = package_url - - @property - def resource_references(self): - """Gets the resource_references of this ApiPipelineVersion. # noqa: E501 - - Input. Required. E.g., specify which pipeline this pipeline version belongs to. # noqa: E501 - - :return: The resource_references of this ApiPipelineVersion. # noqa: E501 - :rtype: list[ApiResourceReference] - """ - return self._resource_references - - @resource_references.setter - def resource_references(self, resource_references): - """Sets the resource_references of this ApiPipelineVersion. - - Input. Required. E.g., specify which pipeline this pipeline version belongs to. # noqa: E501 - - :param resource_references: The resource_references of this ApiPipelineVersion. # noqa: E501 - :type resource_references: list[ApiResourceReference] - """ - - self._resource_references = resource_references - - 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, ApiPipelineVersion): - 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, ApiPipelineVersion): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_relationship.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_relationship.py deleted file mode 100644 index 7daaccc92ba..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_relationship.py +++ /dev/null @@ -1,101 +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 ApiRelationship(object): - """NOTE: This class is auto generated by OpenAPI Generator. - Ref: https://openapi-generator.tech - - Do not edit the class manually. - """ - - """ - allowed enum values - """ - UNKNOWN_RELATIONSHIP = "UNKNOWN_RELATIONSHIP" - OWNER = "OWNER" - CREATOR = "CREATOR" - - allowable_values = [UNKNOWN_RELATIONSHIP, OWNER, CREATOR] # noqa: E501 - - """ - 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 = { - } - - attribute_map = { - } - - def __init__(self, local_vars_configuration=None): # noqa: E501 - """ApiRelationship - 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.discriminator = None - - 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, ApiRelationship): - 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, ApiRelationship): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_key.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_key.py deleted file mode 100644 index 3a888f87411..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_key.py +++ /dev/null @@ -1,148 +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 ApiResourceKey(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 = { - 'type': 'ApiResourceType', - 'id': 'str' - } - - attribute_map = { - 'type': 'type', - 'id': 'id' - } - - def __init__(self, type=None, id=None, local_vars_configuration=None): # noqa: E501 - """ApiResourceKey - 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._type = None - self._id = None - self.discriminator = None - - if type is not None: - self.type = type - if id is not None: - self.id = id - - @property - def type(self): - """Gets the type of this ApiResourceKey. # noqa: E501 - - - :return: The type of this ApiResourceKey. # noqa: E501 - :rtype: ApiResourceType - """ - return self._type - - @type.setter - def type(self, type): - """Sets the type of this ApiResourceKey. - - - :param type: The type of this ApiResourceKey. # noqa: E501 - :type type: ApiResourceType - """ - - self._type = type - - @property - def id(self): - """Gets the id of this ApiResourceKey. # noqa: E501 - - The ID of the resource that referred to. # noqa: E501 - - :return: The id of this ApiResourceKey. # noqa: E501 - :rtype: str - """ - return self._id - - @id.setter - def id(self, id): - """Sets the id of this ApiResourceKey. - - The ID of the resource that referred to. # noqa: E501 - - :param id: The id of this ApiResourceKey. # noqa: E501 - :type id: str - """ - - self._id = id - - 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, ApiResourceKey): - 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, ApiResourceKey): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_reference.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_reference.py deleted file mode 100644 index ee9d30cdae5..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_reference.py +++ /dev/null @@ -1,174 +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 ApiResourceReference(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 = { - 'key': 'ApiResourceKey', - 'name': 'str', - 'relationship': 'ApiRelationship' - } - - attribute_map = { - 'key': 'key', - 'name': 'name', - 'relationship': 'relationship' - } - - def __init__(self, key=None, name=None, relationship=None, local_vars_configuration=None): # noqa: E501 - """ApiResourceReference - 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._key = None - self._name = None - self._relationship = None - self.discriminator = None - - if key is not None: - self.key = key - if name is not None: - self.name = name - if relationship is not None: - self.relationship = relationship - - @property - def key(self): - """Gets the key of this ApiResourceReference. # noqa: E501 - - - :return: The key of this ApiResourceReference. # noqa: E501 - :rtype: ApiResourceKey - """ - return self._key - - @key.setter - def key(self, key): - """Sets the key of this ApiResourceReference. - - - :param key: The key of this ApiResourceReference. # noqa: E501 - :type key: ApiResourceKey - """ - - self._key = key - - @property - def name(self): - """Gets the name of this ApiResourceReference. # noqa: E501 - - The name of the resource that referred to. # noqa: E501 - - :return: The name of this ApiResourceReference. # noqa: E501 - :rtype: str - """ - return self._name - - @name.setter - def name(self, name): - """Sets the name of this ApiResourceReference. - - The name of the resource that referred to. # noqa: E501 - - :param name: The name of this ApiResourceReference. # noqa: E501 - :type name: str - """ - - self._name = name - - @property - def relationship(self): - """Gets the relationship of this ApiResourceReference. # noqa: E501 - - - :return: The relationship of this ApiResourceReference. # noqa: E501 - :rtype: ApiRelationship - """ - return self._relationship - - @relationship.setter - def relationship(self, relationship): - """Sets the relationship of this ApiResourceReference. - - - :param relationship: The relationship of this ApiResourceReference. # noqa: E501 - :type relationship: ApiRelationship - """ - - self._relationship = relationship - - 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, ApiResourceReference): - 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, ApiResourceReference): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_type.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_type.py deleted file mode 100644 index 09905093de6..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_resource_type.py +++ /dev/null @@ -1,104 +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 ApiResourceType(object): - """NOTE: This class is auto generated by OpenAPI Generator. - Ref: https://openapi-generator.tech - - Do not edit the class manually. - """ - - """ - allowed enum values - """ - UNKNOWN_RESOURCE_TYPE = "UNKNOWN_RESOURCE_TYPE" - EXPERIMENT = "EXPERIMENT" - JOB = "JOB" - PIPELINE = "PIPELINE" - PIPELINE_VERSION = "PIPELINE_VERSION" - NAMESPACE = "NAMESPACE" - - allowable_values = [UNKNOWN_RESOURCE_TYPE, EXPERIMENT, JOB, PIPELINE, PIPELINE_VERSION, NAMESPACE] # noqa: E501 - - """ - 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 = { - } - - attribute_map = { - } - - def __init__(self, local_vars_configuration=None): # noqa: E501 - """ApiResourceType - 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.discriminator = None - - 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, ApiResourceType): - 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, ApiResourceType): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_status.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_status.py deleted file mode 100644 index 1e40fdd24ed..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_status.py +++ /dev/null @@ -1,172 +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 ApiStatus(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 = { - 'error': 'str', - 'code': 'int', - 'details': 'list[ProtobufAny]' - } - - attribute_map = { - 'error': 'error', - 'code': 'code', - 'details': 'details' - } - - def __init__(self, error=None, code=None, details=None, local_vars_configuration=None): # noqa: E501 - """ApiStatus - 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._error = None - self._code = None - self._details = None - self.discriminator = None - - if error is not None: - self.error = error - if code is not None: - self.code = code - if details is not None: - self.details = details - - @property - def error(self): - """Gets the error of this ApiStatus. # noqa: E501 - - - :return: The error of this ApiStatus. # noqa: E501 - :rtype: str - """ - return self._error - - @error.setter - def error(self, error): - """Sets the error of this ApiStatus. - - - :param error: The error of this ApiStatus. # noqa: E501 - :type error: str - """ - - self._error = error - - @property - def code(self): - """Gets the code of this ApiStatus. # noqa: E501 - - - :return: The code of this ApiStatus. # noqa: E501 - :rtype: int - """ - return self._code - - @code.setter - def code(self, code): - """Sets the code of this ApiStatus. - - - :param code: The code of this ApiStatus. # noqa: E501 - :type code: int - """ - - self._code = code - - @property - def details(self): - """Gets the details of this ApiStatus. # noqa: E501 - - - :return: The details of this ApiStatus. # noqa: E501 - :rtype: list[ProtobufAny] - """ - return self._details - - @details.setter - def details(self, details): - """Sets the details of this ApiStatus. - - - :param details: The details of this ApiStatus. # noqa: E501 - :type details: list[ProtobufAny] - """ - - self._details = details - - 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, ApiStatus): - 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, ApiStatus): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_url.py b/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_url.py deleted file mode 100644 index 7888e9e6ca2..00000000000 --- a/backend/api/v2beta1/python_http_client/kfp_server_api/models/api_url.py +++ /dev/null @@ -1,120 +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 ApiUrl(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 = { - 'pipeline_url': 'str' - } - - attribute_map = { - 'pipeline_url': 'pipeline_url' - } - - def __init__(self, pipeline_url=None, local_vars_configuration=None): # noqa: E501 - """ApiUrl - 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._pipeline_url = None - self.discriminator = None - - if pipeline_url is not None: - self.pipeline_url = pipeline_url - - @property - def pipeline_url(self): - """Gets the pipeline_url of this ApiUrl. # noqa: E501 - - - :return: The pipeline_url of this ApiUrl. # noqa: E501 - :rtype: str - """ - return self._pipeline_url - - @pipeline_url.setter - def pipeline_url(self, pipeline_url): - """Sets the pipeline_url of this ApiUrl. - - - :param pipeline_url: The pipeline_url of this ApiUrl. # noqa: E501 - :type pipeline_url: str - """ - - self._pipeline_url = pipeline_url - - 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, ApiUrl): - 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, ApiUrl): - return True - - return self.to_dict() != other.to_dict() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_parameter.py b/backend/api/v2beta1/python_http_client/test/test_api_parameter.py deleted file mode 100644 index 9da0d709d73..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_parameter.py +++ /dev/null @@ -1,53 +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.api_parameter import ApiParameter # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiParameter(unittest.TestCase): - """ApiParameter unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiParameter - 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.api_parameter.ApiParameter() # noqa: E501 - if include_optional : - return ApiParameter( - name = '0', - value = '0' - ) - else : - return ApiParameter( - ) - - def testApiParameter(self): - """Test ApiParameter""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_pipeline.py b/backend/api/v2beta1/python_http_client/test/test_api_pipeline.py deleted file mode 100644 index 43f705fafd0..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_pipeline.py +++ /dev/null @@ -1,61 +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.api_pipeline import ApiPipeline # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiPipeline(unittest.TestCase): - """ApiPipeline unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiPipeline - 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.api_pipeline.ApiPipeline() # noqa: E501 - if include_optional : - return ApiPipeline( - id = '0', - created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), - name = '0', - description = '0', - parameters = [ - kfp_server_api.models.api_parameter.apiParameter( - name = '0', - value = '0', ) - ], - error = '0' - ) - else : - return ApiPipeline( - ) - - def testApiPipeline(self): - """Test ApiPipeline""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_pipeline_version.py b/backend/api/v2beta1/python_http_client/test/test_api_pipeline_version.py deleted file mode 100644 index 1d721a07b58..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_pipeline_version.py +++ /dev/null @@ -1,70 +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.api_pipeline_version import ApiPipelineVersion # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiPipelineVersion(unittest.TestCase): - """ApiPipelineVersion unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiPipelineVersion - 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.api_pipeline_version.ApiPipelineVersion() # noqa: E501 - if include_optional : - return ApiPipelineVersion( - id = '0', - name = '0', - created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), - parameters = [ - kfp_server_api.models.api_parameter.apiParameter( - name = '0', - value = '0', ) - ], - code_source_url = '0', - package_url = kfp_server_api.models.api_url.apiUrl( - pipeline_url = '0', ), - resource_references = [ - kfp_server_api.models.api_resource_reference.apiResourceReference( - key = kfp_server_api.models.api_resource_key.apiResourceKey( - type = 'UNKNOWN_RESOURCE_TYPE', - id = '0', ), - name = '0', - relationship = 'UNKNOWN_RELATIONSHIP', ) - ] - ) - else : - return ApiPipelineVersion( - ) - - def testApiPipelineVersion(self): - """Test ApiPipelineVersion""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_relationship.py b/backend/api/v2beta1/python_http_client/test/test_api_relationship.py deleted file mode 100644 index 3e59edffecc..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_relationship.py +++ /dev/null @@ -1,51 +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.api_relationship import ApiRelationship # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiRelationship(unittest.TestCase): - """ApiRelationship unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiRelationship - 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.api_relationship.ApiRelationship() # noqa: E501 - if include_optional : - return ApiRelationship( - ) - else : - return ApiRelationship( - ) - - def testApiRelationship(self): - """Test ApiRelationship""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_resource_key.py b/backend/api/v2beta1/python_http_client/test/test_api_resource_key.py deleted file mode 100644 index a89bc8d3cb1..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_resource_key.py +++ /dev/null @@ -1,53 +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.api_resource_key import ApiResourceKey # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiResourceKey(unittest.TestCase): - """ApiResourceKey unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiResourceKey - 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.api_resource_key.ApiResourceKey() # noqa: E501 - if include_optional : - return ApiResourceKey( - type = 'UNKNOWN_RESOURCE_TYPE', - id = '0' - ) - else : - return ApiResourceKey( - ) - - def testApiResourceKey(self): - """Test ApiResourceKey""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_resource_reference.py b/backend/api/v2beta1/python_http_client/test/test_api_resource_reference.py deleted file mode 100644 index 14507144364..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_resource_reference.py +++ /dev/null @@ -1,56 +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.api_resource_reference import ApiResourceReference # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiResourceReference(unittest.TestCase): - """ApiResourceReference unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiResourceReference - 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.api_resource_reference.ApiResourceReference() # noqa: E501 - if include_optional : - return ApiResourceReference( - key = kfp_server_api.models.api_resource_key.apiResourceKey( - type = 'UNKNOWN_RESOURCE_TYPE', - id = '0', ), - name = '0', - relationship = 'UNKNOWN_RELATIONSHIP' - ) - else : - return ApiResourceReference( - ) - - def testApiResourceReference(self): - """Test ApiResourceReference""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_resource_type.py b/backend/api/v2beta1/python_http_client/test/test_api_resource_type.py deleted file mode 100644 index 8e9c290d319..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_resource_type.py +++ /dev/null @@ -1,51 +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.api_resource_type import ApiResourceType # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiResourceType(unittest.TestCase): - """ApiResourceType unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiResourceType - 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.api_resource_type.ApiResourceType() # noqa: E501 - if include_optional : - return ApiResourceType( - ) - else : - return ApiResourceType( - ) - - def testApiResourceType(self): - """Test ApiResourceType""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_status.py b/backend/api/v2beta1/python_http_client/test/test_api_status.py deleted file mode 100644 index 64b94863a38..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_status.py +++ /dev/null @@ -1,58 +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.api_status import ApiStatus # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiStatus(unittest.TestCase): - """ApiStatus unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiStatus - 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.api_status.ApiStatus() # noqa: E501 - if include_optional : - return ApiStatus( - error = '0', - code = 56, - details = [ - kfp_server_api.models.protobuf_any.protobufAny( - type_url = '0', - value = 'YQ==', ) - ] - ) - else : - return ApiStatus( - ) - - def testApiStatus(self): - """Test ApiStatus""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/python_http_client/test/test_api_url.py b/backend/api/v2beta1/python_http_client/test/test_api_url.py deleted file mode 100644 index eb272ea2908..00000000000 --- a/backend/api/v2beta1/python_http_client/test/test_api_url.py +++ /dev/null @@ -1,52 +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.api_url import ApiUrl # noqa: E501 -from kfp_server_api.rest import ApiException - -class TestApiUrl(unittest.TestCase): - """ApiUrl unit test stubs""" - - def setUp(self): - pass - - def tearDown(self): - pass - - def make_instance(self, include_optional): - """Test ApiUrl - 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.api_url.ApiUrl() # noqa: E501 - if include_optional : - return ApiUrl( - pipeline_url = '0' - ) - else : - return ApiUrl( - ) - - def testApiUrl(self): - """Test ApiUrl""" - inst_req_only = self.make_instance(include_optional=False) - inst_req_and_optional = self.make_instance(include_optional=True) - - -if __name__ == '__main__': - unittest.main() diff --git a/backend/api/v2beta1/swagger/kfp_api_single_file.swagger.json b/backend/api/v2beta1/swagger/kfp_api_single_file.swagger.json index b7da71be713..67f8fbc508b 100644 --- a/backend/api/v2beta1/swagger/kfp_api_single_file.swagger.json +++ b/backend/api/v2beta1/swagger/kfp_api_single_file.swagger.json @@ -668,13 +668,13 @@ "200": { "description": "", "schema": { - "$ref": "#/definitions/apiPipeline" + "$ref": "#/definitions/v2beta1Pipeline" } }, "default": { "description": "", "schema": { - "$ref": "#/definitions/apiStatus" + "$ref": "#/definitions/googlerpcStatus" } } }, @@ -723,13 +723,13 @@ "200": { "description": "", "schema": { - "$ref": "#/definitions/apiPipelineVersion" + "$ref": "#/definitions/v2beta1PipelineVersion" } }, "default": { "description": "", "schema": { - "$ref": "#/definitions/apiStatus" + "$ref": "#/definitions/googlerpcStatus" } } }, @@ -758,12 +758,6 @@ "in": "query", "required": false, "type": "string" - }, - { - "name": "namespace", - "in": "query", - "required": false, - "type": "string" } ], "tags": [ @@ -1783,161 +1777,6 @@ } } }, - "apiParameter": { - "type": "object", - "properties": { - "name": { - "type": "string" - }, - "value": { - "type": "string" - } - } - }, - "apiPipeline": { - "type": "object", - "properties": { - "id": { - "type": "string" - }, - "created_at": { - "type": "string", - "format": "date-time" - }, - "name": { - "type": "string" - }, - "description": { - "type": "string" - }, - "parameters": { - "type": "array", - "items": { - "$ref": "#/definitions/apiParameter" - } - }, - "error": { - "type": "string", - "description": "In case any error happens retrieving a pipeline field, only pipeline ID\nand the error message is returned. Client has the flexibility of choosing\nhow to handle error. This is especially useful during listing call." - } - } - }, - "apiPipelineVersion": { - "type": "object", - "properties": { - "id": { - "type": "string", - "description": "Output. Unique version ID. Generated by API server." - }, - "name": { - "type": "string", - "description": "Optional input field. Version name provided by user." - }, - "created_at": { - "type": "string", - "format": "date-time", - "description": "Output. The time this pipeline version is created." - }, - "parameters": { - "type": "array", - "items": { - "$ref": "#/definitions/apiParameter" - }, - "description": "Output. The input parameters for this pipeline." - }, - "code_source_url": { - "type": "string", - "description": "Input. Optional. Pipeline version code source." - }, - "package_url": { - "$ref": "#/definitions/apiUrl", - "description": "Input. Required. Pipeline version package url.\nWhe calling CreatePipelineVersion API method, need to provide one package\nfile location." - }, - "resource_references": { - "type": "array", - "items": { - "$ref": "#/definitions/apiResourceReference" - }, - "description": "Input. Required. E.g., specify which pipeline this pipeline version belongs\nto." - } - } - }, - "apiRelationship": { - "type": "string", - "enum": [ - "UNKNOWN_RELATIONSHIP", - "OWNER", - "CREATOR" - ], - "default": "UNKNOWN_RELATIONSHIP" - }, - "apiResourceKey": { - "type": "object", - "properties": { - "type": { - "$ref": "#/definitions/apiResourceType", - "description": "The type of the resource that referred to." - }, - "id": { - "type": "string", - "description": "The ID of the resource that referred to." - } - } - }, - "apiResourceReference": { - "type": "object", - "properties": { - "key": { - "$ref": "#/definitions/apiResourceKey" - }, - "name": { - "type": "string", - "description": "The name of the resource that referred to." - }, - "relationship": { - "$ref": "#/definitions/apiRelationship", - "description": "Required field. The relationship from referred resource to the object." - } - } - }, - "apiResourceType": { - "type": "string", - "enum": [ - "UNKNOWN_RESOURCE_TYPE", - "EXPERIMENT", - "JOB", - "PIPELINE", - "PIPELINE_VERSION", - "NAMESPACE" - ], - "default": "UNKNOWN_RESOURCE_TYPE" - }, - "apiStatus": { - "type": "object", - "properties": { - "error": { - "type": "string" - }, - "code": { - "type": "integer", - "format": "int32" - }, - "details": { - "type": "array", - "items": { - "$ref": "#/definitions/protobufAny" - } - } - } - }, - "apiUrl": { - "type": "object", - "properties": { - "pipeline_url": { - "type": "string" - } - } - }, "RecurringRunMode": { "type": "string", "enum": [ diff --git a/backend/api/v2beta1/swagger/pipeline.upload.swagger.json b/backend/api/v2beta1/swagger/pipeline.upload.swagger.json index 689d4c92944..9e0eced84cf 100644 --- a/backend/api/v2beta1/swagger/pipeline.upload.swagger.json +++ b/backend/api/v2beta1/swagger/pipeline.upload.swagger.json @@ -1,313 +1,240 @@ { - "swagger": "2.0", - "info": { - "title": "pipeline upload", - "version": "version not set" - }, - "schemes": [ - "http", - "https" - ], - "paths": { - "/apis/v2beta1/pipelines/upload": { - "post": { - "operationId": "UploadPipeline", - "consumes": [ - "multipart/form-data" - ], - "produces": [ - "application/json" - ], - "responses": { - "200": { - "description": "", - "schema": { - "$ref": "#/definitions/apiPipeline" - } - }, - "default": { - "description": "", - "schema": { - "$ref": "#/definitions/apiStatus" - } - } - }, - "parameters": [ - { - "name": "uploadfile", - "in": "formData", - "required": true, - "type": "file", - "description": "The pipeline to upload. Maximum size of 32MB is supported." - }, - { - "name": "name", - "in": "query", - "required": false, - "type": "string" - }, - { - "name": "description", - "in": "query", - "required": false, - "type": "string" - }, - { - "name": "namespace", - "in": "query", - "required": false, - "type": "string" - } - ], - "tags": [ - "PipelineUploadService" - ] - } - }, - "/apis/v2beta1/pipelines/upload_version": { - "post": { - "operationId": "UploadPipelineVersion", - "consumes": [ - "multipart/form-data" - ], - "produces": [ - "application/json" - ], - "responses": { - "200": { - "description": "", - "schema": { - "$ref": "#/definitions/apiPipelineVersion" - } - }, - "default": { - "description": "", - "schema": { - "$ref": "#/definitions/apiStatus" - } + "swagger": "2.0", + "info": { + "title": "pipeline upload", + "version": "version not set" + }, + "schemes": ["http", "https"], + "paths": { + "/apis/v2beta1/pipelines/upload": { + "post": { + "operationId": "UploadPipeline", + "consumes": ["multipart/form-data"], + "produces": ["application/json"], + "responses": { + "200": { + "description": "", + "schema": { + "$ref": "#/definitions/v2beta1Pipeline" } }, - "parameters": [ - { - "name": "uploadfile", - "in": "formData", - "required": true, - "type": "file", - "description": "The pipeline to upload. Maximum size of 32MB is supported." - }, - { - "name": "name", - "in": "query", - "required": false, - "type": "string" - }, - { - "name": "pipelineid", - "in": "query", - "required": false, - "type": "string" - }, - { - "name": "description", - "in": "query", - "required": false, - "type": "string" - }, - { - "name": "namespace", - "in": "query", - "required": false, - "type": "string" + "default": { + "description": "", + "schema": { + "$ref": "#/definitions/googlerpcStatus" } - ], - "tags": [ - "PipelineUploadService" - ] - } - } - }, - "definitions": { - "apiParameter": { - "type": "object", - "properties": { - "name": { - "type": "string" - }, - "value": { - "type": "string" } - } - }, - "apiPipeline": { - "type": "object", - "properties": { - "id": { + }, + "parameters": [ + { + "name": "uploadfile", + "in": "formData", + "required": true, + "type": "file", + "description": "The pipeline to upload. Maximum size of 32MB is supported." + }, + { + "name": "name", + "in": "query", + "required": false, "type": "string" }, - "created_at": { - "type": "string", - "format": "date-time" - }, - "name": { + { + "name": "description", + "in": "query", + "required": false, "type": "string" }, - "description": { + { + "name": "namespace", + "in": "query", + "required": false, "type": "string" - }, - "parameters": { - "type": "array", - "items": { - "$ref": "#/definitions/apiParameter" - } - }, - "error": { - "type": "string", - "description": "In case any error happens retrieving a pipeline field, only pipeline ID\nand the error message is returned. Client has the flexibility of choosing\nhow to handle error. This is especially useful during listing call." } - } - }, - "apiPipelineVersion": { - "type": "object", - "properties": { - "id": { - "type": "string", - "description": "Output. Unique version ID. Generated by API server." - }, - "name": { - "type": "string", - "description": "Optional input field. Version name provided by user." - }, - "created_at": { - "type": "string", - "format": "date-time", - "description": "Output. The time this pipeline version is created." - }, - "parameters": { - "type": "array", - "items": { - "$ref": "#/definitions/apiParameter" - }, - "description": "Output. The input parameters for this pipeline." - }, - "code_source_url": { - "type": "string", - "description": "Input. Optional. Pipeline version code source." - }, - "package_url": { - "$ref": "#/definitions/apiUrl", - "description": "Input. Required. Pipeline version package url.\nWhe calling CreatePipelineVersion API method, need to provide one package\nfile location." - }, - "resource_references": { - "type": "array", - "items": { - "$ref": "#/definitions/apiResourceReference" - }, - "description": "Input. Required. E.g., specify which pipeline this pipeline version belongs\nto." - } - } - }, - "apiRelationship": { - "type": "string", - "enum": [ - "UNKNOWN_RELATIONSHIP", - "OWNER", - "CREATOR" ], - "default": "UNKNOWN_RELATIONSHIP" - }, - "apiResourceKey": { - "type": "object", - "properties": { - "type": { - "$ref": "#/definitions/apiResourceType", - "description": "The type of the resource that referred to." - }, - "id": { - "type": "string", - "description": "The ID of the resource that referred to." - } - } - }, - "apiResourceReference": { - "type": "object", - "properties": { - "key": { - "$ref": "#/definitions/apiResourceKey" - }, - "name": { - "type": "string", - "description": "The name of the resource that referred to." + "tags": ["PipelineUploadService"] + } + }, + "/apis/v2beta1/pipelines/upload_version": { + "post": { + "operationId": "UploadPipelineVersion", + "consumes": ["multipart/form-data"], + "produces": ["application/json"], + "responses": { + "200": { + "description": "", + "schema": { + "$ref": "#/definitions/v2beta1PipelineVersion" + } }, - "relationship": { - "$ref": "#/definitions/apiRelationship", - "description": "Required field. The relationship from referred resource to the object." + "default": { + "description": "", + "schema": { + "$ref": "#/definitions/googlerpcStatus" + } } - } - }, - "apiResourceType": { - "type": "string", - "enum": [ - "UNKNOWN_RESOURCE_TYPE", - "EXPERIMENT", - "JOB", - "PIPELINE", - "PIPELINE_VERSION", - "NAMESPACE" - ], - "default": "UNKNOWN_RESOURCE_TYPE" - }, - "apiStatus": { - "type": "object", - "properties": { - "error": { + }, + "parameters": [ + { + "name": "uploadfile", + "in": "formData", + "required": true, + "type": "file", + "description": "The pipeline to upload. Maximum size of 32MB is supported." + }, + { + "name": "name", + "in": "query", + "required": false, "type": "string" }, - "code": { - "type": "integer", - "format": "int32" - }, - "details": { - "type": "array", - "items": { - "$ref": "#/definitions/protobufAny" - } - } - } - }, - "apiUrl": { - "type": "object", - "properties": { - "pipeline_url": { + { + "name": "pipelineid", + "in": "query", + "required": false, "type": "string" - } - } - }, - "protobufAny": { - "type": "object", - "properties": { - "type_url": { - "type": "string", - "description": "A URL/resource name that uniquely identifies the type of the serialized\nprotocol buffer message. The last segment of the URL's path must represent\nthe fully qualified name of the type (as in\n`path/google.protobuf.Duration`). The name should be in a canonical form\n(e.g., leading \".\" is not accepted).\n\nIn practice, teams usually precompile into the binary all types that they\nexpect it to use in the context of Any. However, for URLs which use the\nscheme `http`, `https`, or no scheme, one can optionally set up a type\nserver that maps type URLs to message definitions as follows:\n\n* If no scheme is provided, `https` is assumed.\n* An HTTP GET on the URL must yield a [google.protobuf.Type][]\n value in binary format, or produce an error.\n* Applications are allowed to cache lookup results based on the\n URL, or have them precompiled into a binary to avoid any\n lookup. Therefore, binary compatibility needs to be preserved\n on changes to types. (Use versioned type names to manage\n breaking changes.)\n\nNote: this functionality is not currently available in the official\nprotobuf release, and it is not used for type URLs beginning with\ntype.googleapis.com.\n\nSchemes other than `http`, `https` (or the empty scheme) might be\nused with implementation specific semantics." }, - "value": { - "type": "string", - "format": "byte", - "description": "Must be a valid serialized protocol buffer of the above specified type." + { + "name": "description", + "in": "query", + "required": false, + "type": "string" } + ], + "tags": ["PipelineUploadService"] + } + } + }, + "definitions": { + "v2beta1Pipeline": { + "type": "object", + "properties": { + "pipeline_id": { + "type": "string", + "description": "Output. Unique pipeline ID. Generated by API server." }, - "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 := ptypes.MarshalAny(foo)\n ...\n foo := \u0026pb.Foo{}\n if err := ptypes.UnmarshalAny(any, 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 }" + "display_name": { + "type": "string", + "description": "Required input field. Pipeline name provided by user." + }, + "description": { + "type": "string", + "description": "Optional input field. A short description of the pipeline." + }, + "created_at": { + "type": "string", + "format": "date-time", + "description": "Output. Creation time of the pipeline." + }, + "namespace": { + "type": "string", + "description": "Input. A namespace this pipeline belongs to.\nCauses error if user is not authorized to access the specified namespace.\nIf not specified in CreatePipeline, default namespace is used." + }, + "error": { + "$ref": "#/definitions/googlerpcStatus", + "description": "In case any error happens retrieving a pipeline field, only pipeline ID,\nand the error message is returned. Client has the flexibility of choosing\nhow to handle the error. This is especially useful during listing call." + } } }, - "securityDefinitions": { - "Bearer": { - "type": "apiKey", - "name": "authorization", - "in": "header" + "v2beta1PipelineVersion": { + "type": "object", + "properties": { + "pipeline_id": { + "type": "string", + "description": "Required input field. Unique ID of the parent pipeline." + }, + "pipeline_version_id": { + "type": "string", + "description": "Output. Unique pipeline version ID. Generated by API server." + }, + "display_name": { + "type": "string", + "description": "Required input field. Pipeline version name provided by user." + }, + "description": { + "type": "string", + "description": "Optional input field. Short description of the pipeline version." + }, + "created_at": { + "type": "string", + "format": "date-time", + "description": "Output. Creation time of the pipeline version." + }, + "package_url": { + "$ref": "#/definitions/v2beta1Url", + "description": "Input. Required. The URL to the source of the pipeline version.\nThis is required when creating the pipeine version through\nCreatePipelineVersion API." + }, + "code_source_url": { + "type": "string", + "description": "Input. Optional. The URL to the code source of the pipeline version.\nThe code is usually the Python definition of the pipeline and potentially\nrelated the component definitions. This allows users to trace back to how\nthe pipeline YAML was created." + }, + "pipeline_spec": { + "type": "object", + "description": "Output. The pipeline spec for the pipeline version." + }, + "error": { + "$ref": "#/definitions/googlerpcStatus", + "description": "In case any error happens retrieving a pipeline version field, only\npipeline ID, pipeline version ID, and the error message are returned. \nClient has the flexibility of choosing how to handle the error. \nThis is especially useful during List() calls." + } } }, - "security": [ - { - "Bearer": [] + "v2beta1Url": { + "type": "object", + "properties": { + "pipeline_url": { + "type": "string", + "description": "URL of the pipeline version definition." + } } - ] - } + }, + "googlerpcStatus": { + "type": "object", + "properties": { + "code": { + "type": "integer", + "format": "int32", + "description": "The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code]." + }, + "message": { + "type": "string", + "description": "A developer-facing error message, which should be in English. Any\nuser-facing error message should be localized and sent in the\n[google.rpc.Status.details][google.rpc.Status.details] field, or localized by the client." + }, + "details": { + "type": "array", + "items": { + "$ref": "#/definitions/protobufAny" + }, + "description": "A list of messages that carry the error details. There is a common set of\nmessage types for APIs to use." + } + }, + "description": "The `Status` type defines a logical error model that is suitable for\ndifferent programming environments, including REST APIs and RPC APIs. It is\nused by [gRPC](https://github.com/grpc). Each `Status` message contains\nthree pieces of data: error code, error message, and error details.\n\nYou can find out more about this error model and how to work with it in the\n[API Design Guide](https://cloud.google.com/apis/design/errors)." + }, + "protobufAny": { + "type": "object", + "properties": { + "type_url": { + "type": "string", + "description": "A URL/resource name that uniquely identifies the type of the serialized\nprotocol buffer message. The last segment of the URL's path must represent\nthe fully qualified name of the type (as in\n`path/google.protobuf.Duration`). The name should be in a canonical form\n(e.g., leading \".\" is not accepted).\n\nIn practice, teams usually precompile into the binary all types that they\nexpect it to use in the context of Any. However, for URLs which use the\nscheme `http`, `https`, or no scheme, one can optionally set up a type\nserver that maps type URLs to message definitions as follows:\n\n* If no scheme is provided, `https` is assumed.\n* An HTTP GET on the URL must yield a [google.protobuf.Type][]\n value in binary format, or produce an error.\n* Applications are allowed to cache lookup results based on the\n URL, or have them precompiled into a binary to avoid any\n lookup. Therefore, binary compatibility needs to be preserved\n on changes to types. (Use versioned type names to manage\n breaking changes.)\n\nNote: this functionality is not currently available in the official\nprotobuf release, and it is not used for type URLs beginning with\ntype.googleapis.com.\n\nSchemes other than `http`, `https` (or the empty scheme) might be\nused with implementation specific semantics." + }, + "value": { + "type": "string", + "format": "byte", + "description": "Must be a valid serialized protocol buffer of the above specified type." + } + }, + "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 := ptypes.MarshalAny(foo)\n ...\n foo := \u0026pb.Foo{}\n if err := ptypes.UnmarshalAny(any, 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 }" + } + }, + "securityDefinitions": { + "Bearer": { + "type": "apiKey", + "name": "authorization", + "in": "header" + } + }, + "security": [ + { + "Bearer": [] + } + ] +}