diff --git a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go index 7b84e75399d..6180f6ae4de 100644 --- a/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go +++ b/api/v2alpha1/go/pipelinespec/pipeline_spec.pb.go @@ -2005,12 +2005,16 @@ func (x *ArtifactList) GetArtifacts() []*RuntimeArtifact { // artifact. // `{{$.inputs.artifacts[''].properties['']}}`: prints // the -// property of an input artifact. +// +// property of an input artifact. +// // `{{$.inputs.parameters['']}}`: prints the value of an input // parameter. // `{{$.outputs.artifacts[''].uri}}: prints the URI of an output artifact. // `{{$.outputs.artifacts[''].properties['']}}`: prints the -// property of an output artifact. +// +// property of an output artifact. +// // `{{$.outputs.parameters[''].output_file}}`: prints a file path which // points to a file and container can write to it to return the value of the // parameter.. diff --git a/backend/api/go_client/filter.pb.go b/backend/api/go_client/filter.pb.go index 82c2995d0d4..64cdec9d543 100644 --- a/backend/api/go_client/filter.pb.go +++ b/backend/api/go_client/filter.pb.go @@ -431,40 +431,46 @@ func (x *LongValues) GetValues() []int64 { // Example filters: // 1) Filter runs with status = 'Running' // filter { -// predicate { -// key: "status" -// op: EQUALS -// string_value: "Running" -// } +// +// predicate { +// key: "status" +// op: EQUALS +// string_value: "Running" +// } +// // } // // 2) Filter runs that succeeded since Dec 1, 2018 // filter { -// predicate { -// key: "status" -// op: EQUALS -// string_value: "Succeeded" -// } -// predicate { -// key: "created_at" -// op: GREATER_THAN -// timestamp_value { -// seconds: 1543651200 -// } -// } +// +// predicate { +// key: "status" +// op: EQUALS +// string_value: "Succeeded" +// } +// predicate { +// key: "created_at" +// op: GREATER_THAN +// timestamp_value { +// seconds: 1543651200 +// } +// } +// // } // // 3) Filter runs with one of labels 'label_1' or 'label_2' // // filter { -// predicate { -// key: "label" -// op: IN -// string_values { -// value: 'label_1' -// value: 'label_2' -// } -// } +// +// predicate { +// key: "label" +// op: IN +// string_values { +// value: 'label_1' +// value: 'label_2' +// } +// } +// // } type Filter struct { state protoimpl.MessageState diff --git a/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_parameters.go index 51b7262ccda..71f96970392 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_parameters.go @@ -56,7 +56,8 @@ func NewArchiveExperimentParamsWithHTTPClient(client *http.Client) *ArchiveExper } } -/*ArchiveExperimentParams contains all the parameters to send to the API endpoint +/* +ArchiveExperimentParams contains all the parameters to send to the API endpoint for the archive experiment operation typically these are written to a http.Request */ type ArchiveExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_responses.go index b305ed6902d..c7a8c943093 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/archive_experiment_responses.go @@ -49,7 +49,8 @@ func NewArchiveExperimentOK() *ArchiveExperimentOK { return &ArchiveExperimentOK{} } -/*ArchiveExperimentOK handles this case with default header values. +/* +ArchiveExperimentOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewArchiveExperimentDefault(code int) *ArchiveExperimentDefault { } } -/*ArchiveExperimentDefault handles this case with default header values. +/* +ArchiveExperimentDefault handles this case with default header values. ArchiveExperimentDefault archive experiment default */ diff --git a/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_parameters.go index 9f2d99a928c..2e8239b8517 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_parameters.go @@ -58,7 +58,8 @@ func NewCreateExperimentParamsWithHTTPClient(client *http.Client) *CreateExperim } } -/*CreateExperimentParams contains all the parameters to send to the API endpoint +/* +CreateExperimentParams contains all the parameters to send to the API endpoint for the create experiment operation typically these are written to a http.Request */ type CreateExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_responses.go index aaf04cb0bf9..58387a65715 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/create_experiment_responses.go @@ -49,7 +49,8 @@ func NewCreateExperimentOK() *CreateExperimentOK { return &CreateExperimentOK{} } -/*CreateExperimentOK handles this case with default header values. +/* +CreateExperimentOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreateExperimentDefault(code int) *CreateExperimentDefault { } } -/*CreateExperimentDefault handles this case with default header values. +/* +CreateExperimentDefault handles this case with default header values. CreateExperimentDefault create experiment default */ diff --git a/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_parameters.go index d2ad3fca081..7b331172811 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_parameters.go @@ -56,7 +56,8 @@ func NewDeleteExperimentParamsWithHTTPClient(client *http.Client) *DeleteExperim } } -/*DeleteExperimentParams contains all the parameters to send to the API endpoint +/* +DeleteExperimentParams contains all the parameters to send to the API endpoint for the delete experiment operation typically these are written to a http.Request */ type DeleteExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_responses.go index 9faabcaf839..d41213d2f4d 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/delete_experiment_responses.go @@ -49,7 +49,8 @@ func NewDeleteExperimentOK() *DeleteExperimentOK { return &DeleteExperimentOK{} } -/*DeleteExperimentOK handles this case with default header values. +/* +DeleteExperimentOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDeleteExperimentDefault(code int) *DeleteExperimentDefault { } } -/*DeleteExperimentDefault handles this case with default header values. +/* +DeleteExperimentDefault handles this case with default header values. DeleteExperimentDefault delete experiment default */ diff --git a/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_parameters.go index 9bacdf41c85..ae0c4c905dd 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_parameters.go @@ -56,7 +56,8 @@ func NewGetExperimentParamsWithHTTPClient(client *http.Client) *GetExperimentPar } } -/*GetExperimentParams contains all the parameters to send to the API endpoint +/* +GetExperimentParams contains all the parameters to send to the API endpoint for the get experiment operation typically these are written to a http.Request */ type GetExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_responses.go index 3cfcc035b06..dc70d0518d2 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/get_experiment_responses.go @@ -49,7 +49,8 @@ func NewGetExperimentOK() *GetExperimentOK { return &GetExperimentOK{} } -/*GetExperimentOK handles this case with default header values. +/* +GetExperimentOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetExperimentDefault(code int) *GetExperimentDefault { } } -/*GetExperimentDefault handles this case with default header values. +/* +GetExperimentDefault handles this case with default header values. GetExperimentDefault get experiment default */ diff --git a/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_parameters.go index 1525b0bc8f6..4782f11f68b 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_parameters.go @@ -69,7 +69,8 @@ func NewListExperimentParamsWithHTTPClient(client *http.Client) *ListExperimentP } } -/*ListExperimentParams contains all the parameters to send to the API endpoint +/* +ListExperimentParams contains all the parameters to send to the API endpoint for the list experiment operation typically these are written to a http.Request */ type ListExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_responses.go index 3169fb5b2fe..b568c56265d 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/list_experiment_responses.go @@ -49,7 +49,8 @@ func NewListExperimentOK() *ListExperimentOK { return &ListExperimentOK{} } -/*ListExperimentOK handles this case with default header values. +/* +ListExperimentOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewListExperimentDefault(code int) *ListExperimentDefault { } } -/*ListExperimentDefault handles this case with default header values. +/* +ListExperimentDefault handles this case with default header values. ListExperimentDefault list experiment default */ diff --git a/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_parameters.go b/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_parameters.go index 1a21b986025..2e6fe42bffa 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_parameters.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_parameters.go @@ -56,7 +56,8 @@ func NewUnarchiveExperimentParamsWithHTTPClient(client *http.Client) *UnarchiveE } } -/*UnarchiveExperimentParams contains all the parameters to send to the API endpoint +/* +UnarchiveExperimentParams contains all the parameters to send to the API endpoint for the unarchive experiment operation typically these are written to a http.Request */ type UnarchiveExperimentParams struct { diff --git a/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_responses.go b/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_responses.go index b7101151366..3af385a2074 100644 --- a/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_responses.go +++ b/backend/api/go_http_client/experiment_client/experiment_service/unarchive_experiment_responses.go @@ -49,7 +49,8 @@ func NewUnarchiveExperimentOK() *UnarchiveExperimentOK { return &UnarchiveExperimentOK{} } -/*UnarchiveExperimentOK handles this case with default header values. +/* +UnarchiveExperimentOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewUnarchiveExperimentDefault(code int) *UnarchiveExperimentDefault { } } -/*UnarchiveExperimentDefault handles this case with default header values. +/* +UnarchiveExperimentDefault handles this case with default header values. UnarchiveExperimentDefault unarchive experiment default */ diff --git a/backend/api/go_http_client/experiment_model/protobuf_any.go b/backend/api/go_http_client/experiment_model/protobuf_any.go index 9d87904decd..88e8345c252 100644 --- a/backend/api/go_http_client/experiment_model/protobuf_any.go +++ b/backend/api/go_http_client/experiment_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_parameters.go b/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_parameters.go index b03e4c1c459..232e3992fc6 100644 --- a/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_parameters.go +++ b/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_parameters.go @@ -56,7 +56,8 @@ func NewGetHealthzParamsWithHTTPClient(client *http.Client) *GetHealthzParams { } } -/*GetHealthzParams contains all the parameters to send to the API endpoint +/* +GetHealthzParams contains all the parameters to send to the API endpoint for the get healthz operation typically these are written to a http.Request */ type GetHealthzParams struct { diff --git a/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_responses.go b/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_responses.go index ae54da8a4d0..cac6e12aeaf 100644 --- a/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_responses.go +++ b/backend/api/go_http_client/healthz_client/healthz_service/get_healthz_responses.go @@ -49,7 +49,8 @@ func NewGetHealthzOK() *GetHealthzOK { return &GetHealthzOK{} } -/*GetHealthzOK handles this case with default header values. +/* +GetHealthzOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetHealthzDefault(code int) *GetHealthzDefault { } } -/*GetHealthzDefault handles this case with default header values. +/* +GetHealthzDefault handles this case with default header values. GetHealthzDefault get healthz default */ diff --git a/backend/api/go_http_client/healthz_model/protobuf_any.go b/backend/api/go_http_client/healthz_model/protobuf_any.go index 52a0e70e647..60e669ee320 100644 --- a/backend/api/go_http_client/healthz_model/protobuf_any.go +++ b/backend/api/go_http_client/healthz_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/job_client/job_service/create_job_parameters.go b/backend/api/go_http_client/job_client/job_service/create_job_parameters.go index 933fc1f0120..d3c175655bf 100644 --- a/backend/api/go_http_client/job_client/job_service/create_job_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/create_job_parameters.go @@ -58,7 +58,8 @@ func NewCreateJobParamsWithHTTPClient(client *http.Client) *CreateJobParams { } } -/*CreateJobParams contains all the parameters to send to the API endpoint +/* +CreateJobParams contains all the parameters to send to the API endpoint for the create job operation typically these are written to a http.Request */ type CreateJobParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/create_job_responses.go b/backend/api/go_http_client/job_client/job_service/create_job_responses.go index 1a22c09cb1c..500a3622be2 100644 --- a/backend/api/go_http_client/job_client/job_service/create_job_responses.go +++ b/backend/api/go_http_client/job_client/job_service/create_job_responses.go @@ -49,7 +49,8 @@ func NewCreateJobOK() *CreateJobOK { return &CreateJobOK{} } -/*CreateJobOK handles this case with default header values. +/* +CreateJobOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreateJobDefault(code int) *CreateJobDefault { } } -/*CreateJobDefault handles this case with default header values. +/* +CreateJobDefault handles this case with default header values. CreateJobDefault create job default */ diff --git a/backend/api/go_http_client/job_client/job_service/delete_job_parameters.go b/backend/api/go_http_client/job_client/job_service/delete_job_parameters.go index c68b144fab6..fe68b61f4b3 100644 --- a/backend/api/go_http_client/job_client/job_service/delete_job_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/delete_job_parameters.go @@ -56,7 +56,8 @@ func NewDeleteJobParamsWithHTTPClient(client *http.Client) *DeleteJobParams { } } -/*DeleteJobParams contains all the parameters to send to the API endpoint +/* +DeleteJobParams contains all the parameters to send to the API endpoint for the delete job operation typically these are written to a http.Request */ type DeleteJobParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/delete_job_responses.go b/backend/api/go_http_client/job_client/job_service/delete_job_responses.go index 36e5a26d07a..45b50d17b74 100644 --- a/backend/api/go_http_client/job_client/job_service/delete_job_responses.go +++ b/backend/api/go_http_client/job_client/job_service/delete_job_responses.go @@ -49,7 +49,8 @@ func NewDeleteJobOK() *DeleteJobOK { return &DeleteJobOK{} } -/*DeleteJobOK handles this case with default header values. +/* +DeleteJobOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDeleteJobDefault(code int) *DeleteJobDefault { } } -/*DeleteJobDefault handles this case with default header values. +/* +DeleteJobDefault handles this case with default header values. DeleteJobDefault delete job default */ diff --git a/backend/api/go_http_client/job_client/job_service/disable_job_parameters.go b/backend/api/go_http_client/job_client/job_service/disable_job_parameters.go index 3613607ddb1..b085207da5a 100644 --- a/backend/api/go_http_client/job_client/job_service/disable_job_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/disable_job_parameters.go @@ -56,7 +56,8 @@ func NewDisableJobParamsWithHTTPClient(client *http.Client) *DisableJobParams { } } -/*DisableJobParams contains all the parameters to send to the API endpoint +/* +DisableJobParams contains all the parameters to send to the API endpoint for the disable job operation typically these are written to a http.Request */ type DisableJobParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/disable_job_responses.go b/backend/api/go_http_client/job_client/job_service/disable_job_responses.go index 101f8e59869..472e09c47c3 100644 --- a/backend/api/go_http_client/job_client/job_service/disable_job_responses.go +++ b/backend/api/go_http_client/job_client/job_service/disable_job_responses.go @@ -49,7 +49,8 @@ func NewDisableJobOK() *DisableJobOK { return &DisableJobOK{} } -/*DisableJobOK handles this case with default header values. +/* +DisableJobOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDisableJobDefault(code int) *DisableJobDefault { } } -/*DisableJobDefault handles this case with default header values. +/* +DisableJobDefault handles this case with default header values. DisableJobDefault disable job default */ diff --git a/backend/api/go_http_client/job_client/job_service/enable_job_parameters.go b/backend/api/go_http_client/job_client/job_service/enable_job_parameters.go index 0d98cfc591c..a8d0bc9e103 100644 --- a/backend/api/go_http_client/job_client/job_service/enable_job_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/enable_job_parameters.go @@ -56,7 +56,8 @@ func NewEnableJobParamsWithHTTPClient(client *http.Client) *EnableJobParams { } } -/*EnableJobParams contains all the parameters to send to the API endpoint +/* +EnableJobParams contains all the parameters to send to the API endpoint for the enable job operation typically these are written to a http.Request */ type EnableJobParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/enable_job_responses.go b/backend/api/go_http_client/job_client/job_service/enable_job_responses.go index 12c31aa7a96..cf19cca29db 100644 --- a/backend/api/go_http_client/job_client/job_service/enable_job_responses.go +++ b/backend/api/go_http_client/job_client/job_service/enable_job_responses.go @@ -49,7 +49,8 @@ func NewEnableJobOK() *EnableJobOK { return &EnableJobOK{} } -/*EnableJobOK handles this case with default header values. +/* +EnableJobOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewEnableJobDefault(code int) *EnableJobDefault { } } -/*EnableJobDefault handles this case with default header values. +/* +EnableJobDefault handles this case with default header values. EnableJobDefault enable job default */ diff --git a/backend/api/go_http_client/job_client/job_service/get_job_parameters.go b/backend/api/go_http_client/job_client/job_service/get_job_parameters.go index 1b11cb2dfc4..9791e39f774 100644 --- a/backend/api/go_http_client/job_client/job_service/get_job_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/get_job_parameters.go @@ -56,7 +56,8 @@ func NewGetJobParamsWithHTTPClient(client *http.Client) *GetJobParams { } } -/*GetJobParams contains all the parameters to send to the API endpoint +/* +GetJobParams contains all the parameters to send to the API endpoint for the get job operation typically these are written to a http.Request */ type GetJobParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/get_job_responses.go b/backend/api/go_http_client/job_client/job_service/get_job_responses.go index 9f1dd6289a9..a3251e47f7c 100644 --- a/backend/api/go_http_client/job_client/job_service/get_job_responses.go +++ b/backend/api/go_http_client/job_client/job_service/get_job_responses.go @@ -49,7 +49,8 @@ func NewGetJobOK() *GetJobOK { return &GetJobOK{} } -/*GetJobOK handles this case with default header values. +/* +GetJobOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetJobDefault(code int) *GetJobDefault { } } -/*GetJobDefault handles this case with default header values. +/* +GetJobDefault handles this case with default header values. GetJobDefault get job default */ diff --git a/backend/api/go_http_client/job_client/job_service/list_jobs_parameters.go b/backend/api/go_http_client/job_client/job_service/list_jobs_parameters.go index d81ecd228a6..fe03d9323cd 100644 --- a/backend/api/go_http_client/job_client/job_service/list_jobs_parameters.go +++ b/backend/api/go_http_client/job_client/job_service/list_jobs_parameters.go @@ -69,7 +69,8 @@ func NewListJobsParamsWithHTTPClient(client *http.Client) *ListJobsParams { } } -/*ListJobsParams contains all the parameters to send to the API endpoint +/* +ListJobsParams contains all the parameters to send to the API endpoint for the list jobs operation typically these are written to a http.Request */ type ListJobsParams struct { diff --git a/backend/api/go_http_client/job_client/job_service/list_jobs_responses.go b/backend/api/go_http_client/job_client/job_service/list_jobs_responses.go index 7c3d5534eaf..f1f00e4577b 100644 --- a/backend/api/go_http_client/job_client/job_service/list_jobs_responses.go +++ b/backend/api/go_http_client/job_client/job_service/list_jobs_responses.go @@ -49,7 +49,8 @@ func NewListJobsOK() *ListJobsOK { return &ListJobsOK{} } -/*ListJobsOK handles this case with default header values. +/* +ListJobsOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewListJobsDefault(code int) *ListJobsDefault { } } -/*ListJobsDefault handles this case with default header values. +/* +ListJobsDefault handles this case with default header values. ListJobsDefault list jobs default */ diff --git a/backend/api/go_http_client/job_model/job_mode.go b/backend/api/go_http_client/job_model/job_mode.go index bb24a144823..b31268e66b7 100644 --- a/backend/api/go_http_client/job_model/job_mode.go +++ b/backend/api/go_http_client/job_model/job_mode.go @@ -16,7 +16,8 @@ import ( // JobMode Required input. // -// - DISABLED: The job won't schedule any run if disabled. +// - DISABLED: The job won't schedule any run if disabled. +// // swagger:model JobMode type JobMode string diff --git a/backend/api/go_http_client/job_model/protobuf_any.go b/backend/api/go_http_client/job_model/protobuf_any.go index 543426bef64..f49d9cb83d4 100644 --- a/backend/api/go_http_client/job_model/protobuf_any.go +++ b/backend/api/go_http_client/job_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/job_model/protobuf_null_value.go b/backend/api/go_http_client/job_model/protobuf_null_value.go index c5f2c520a2b..53f203dc9d9 100644 --- a/backend/api/go_http_client/job_model/protobuf_null_value.go +++ b/backend/api/go_http_client/job_model/protobuf_null_value.go @@ -17,9 +17,10 @@ import ( // ProtobufNullValue `NullValue` is a singleton enumeration to represent the null value for the // `Value` type union. // -// The JSON representation for `NullValue` is JSON `null`. +// The JSON representation for `NullValue` is JSON `null`. +// +// - NULL_VALUE: Null value. // -// - NULL_VALUE: Null value. // swagger:model protobufNullValue type ProtobufNullValue string diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_parameters.go index 08c94f7d008..98b23216e76 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_parameters.go @@ -58,7 +58,8 @@ func NewCreatePipelineParamsWithHTTPClient(client *http.Client) *CreatePipelineP } } -/*CreatePipelineParams contains all the parameters to send to the API endpoint +/* +CreatePipelineParams contains all the parameters to send to the API endpoint for the create pipeline operation typically these are written to a http.Request */ type CreatePipelineParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_responses.go index d38295a1e58..f51453b512b 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_responses.go @@ -49,7 +49,8 @@ func NewCreatePipelineOK() *CreatePipelineOK { return &CreatePipelineOK{} } -/*CreatePipelineOK handles this case with default header values. +/* +CreatePipelineOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreatePipelineDefault(code int) *CreatePipelineDefault { } } -/*CreatePipelineDefault handles this case with default header values. +/* +CreatePipelineDefault handles this case with default header values. CreatePipelineDefault create pipeline default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_parameters.go index 1837903ba78..fa9175715da 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_parameters.go @@ -58,7 +58,8 @@ func NewCreatePipelineVersionParamsWithHTTPClient(client *http.Client) *CreatePi } } -/*CreatePipelineVersionParams contains all the parameters to send to the API endpoint +/* +CreatePipelineVersionParams contains all the parameters to send to the API endpoint for the create pipeline version operation typically these are written to a http.Request */ type CreatePipelineVersionParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_responses.go index e01c4f80339..def8bfaa0b5 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/create_pipeline_version_responses.go @@ -49,7 +49,8 @@ func NewCreatePipelineVersionOK() *CreatePipelineVersionOK { return &CreatePipelineVersionOK{} } -/*CreatePipelineVersionOK handles this case with default header values. +/* +CreatePipelineVersionOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreatePipelineVersionDefault(code int) *CreatePipelineVersionDefault { } } -/*CreatePipelineVersionDefault handles this case with default header values. +/* +CreatePipelineVersionDefault handles this case with default header values. CreatePipelineVersionDefault create pipeline version default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_parameters.go index 0fd3417789f..5ced253754c 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_parameters.go @@ -56,7 +56,8 @@ func NewDeletePipelineParamsWithHTTPClient(client *http.Client) *DeletePipelineP } } -/*DeletePipelineParams contains all the parameters to send to the API endpoint +/* +DeletePipelineParams contains all the parameters to send to the API endpoint for the delete pipeline operation typically these are written to a http.Request */ type DeletePipelineParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_responses.go index f8dd070236b..09a1cea2769 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_responses.go @@ -49,7 +49,8 @@ func NewDeletePipelineOK() *DeletePipelineOK { return &DeletePipelineOK{} } -/*DeletePipelineOK handles this case with default header values. +/* +DeletePipelineOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDeletePipelineDefault(code int) *DeletePipelineDefault { } } -/*DeletePipelineDefault handles this case with default header values. +/* +DeletePipelineDefault handles this case with default header values. DeletePipelineDefault delete pipeline default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_parameters.go index d8718fe0930..5db9acbf5f5 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_parameters.go @@ -56,7 +56,8 @@ func NewDeletePipelineVersionParamsWithHTTPClient(client *http.Client) *DeletePi } } -/*DeletePipelineVersionParams contains all the parameters to send to the API endpoint +/* +DeletePipelineVersionParams contains all the parameters to send to the API endpoint for the delete pipeline version operation typically these are written to a http.Request */ type DeletePipelineVersionParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_responses.go index c0c163ea3e7..0cbf808c991 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/delete_pipeline_version_responses.go @@ -49,7 +49,8 @@ func NewDeletePipelineVersionOK() *DeletePipelineVersionOK { return &DeletePipelineVersionOK{} } -/*DeletePipelineVersionOK handles this case with default header values. +/* +DeletePipelineVersionOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDeletePipelineVersionDefault(code int) *DeletePipelineVersionDefault { } } -/*DeletePipelineVersionDefault handles this case with default header values. +/* +DeletePipelineVersionDefault handles this case with default header values. DeletePipelineVersionDefault delete pipeline version default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_parameters.go index 14ae32f324d..2949d53d722 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_parameters.go @@ -56,7 +56,8 @@ func NewGetPipelineByNameParamsWithHTTPClient(client *http.Client) *GetPipelineB } } -/*GetPipelineByNameParams contains all the parameters to send to the API endpoint +/* +GetPipelineByNameParams contains all the parameters to send to the API endpoint for the get pipeline by name operation typically these are written to a http.Request */ type GetPipelineByNameParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_responses.go index f094372e95b..b46acd55a1d 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_by_name_responses.go @@ -49,7 +49,8 @@ func NewGetPipelineByNameOK() *GetPipelineByNameOK { return &GetPipelineByNameOK{} } -/*GetPipelineByNameOK handles this case with default header values. +/* +GetPipelineByNameOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetPipelineByNameDefault(code int) *GetPipelineByNameDefault { } } -/*GetPipelineByNameDefault handles this case with default header values. +/* +GetPipelineByNameDefault handles this case with default header values. GetPipelineByNameDefault get pipeline by name default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_parameters.go index 499511d87f1..f5b08fbf9a5 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_parameters.go @@ -56,7 +56,8 @@ func NewGetPipelineParamsWithHTTPClient(client *http.Client) *GetPipelineParams } } -/*GetPipelineParams contains all the parameters to send to the API endpoint +/* +GetPipelineParams contains all the parameters to send to the API endpoint for the get pipeline operation typically these are written to a http.Request */ type GetPipelineParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_responses.go index 5c9b7e5f7dc..ada60403235 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_responses.go @@ -49,7 +49,8 @@ func NewGetPipelineOK() *GetPipelineOK { return &GetPipelineOK{} } -/*GetPipelineOK handles this case with default header values. +/* +GetPipelineOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetPipelineDefault(code int) *GetPipelineDefault { } } -/*GetPipelineDefault handles this case with default header values. +/* +GetPipelineDefault handles this case with default header values. GetPipelineDefault get pipeline default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_parameters.go index 4ed8b98ddae..ae8d5b10be5 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_parameters.go @@ -56,7 +56,8 @@ func NewGetPipelineVersionParamsWithHTTPClient(client *http.Client) *GetPipeline } } -/*GetPipelineVersionParams contains all the parameters to send to the API endpoint +/* +GetPipelineVersionParams contains all the parameters to send to the API endpoint for the get pipeline version operation typically these are written to a http.Request */ type GetPipelineVersionParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_responses.go index f08e7dfa011..0c5c5095f6d 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_responses.go @@ -49,7 +49,8 @@ func NewGetPipelineVersionOK() *GetPipelineVersionOK { return &GetPipelineVersionOK{} } -/*GetPipelineVersionOK handles this case with default header values. +/* +GetPipelineVersionOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetPipelineVersionDefault(code int) *GetPipelineVersionDefault { } } -/*GetPipelineVersionDefault handles this case with default header values. +/* +GetPipelineVersionDefault handles this case with default header values. GetPipelineVersionDefault get pipeline version default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_parameters.go index b5291d9d7ab..661a17c4986 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_parameters.go @@ -56,7 +56,8 @@ func NewGetPipelineVersionTemplateParamsWithHTTPClient(client *http.Client) *Get } } -/*GetPipelineVersionTemplateParams contains all the parameters to send to the API endpoint +/* +GetPipelineVersionTemplateParams contains all the parameters to send to the API endpoint for the get pipeline version template operation typically these are written to a http.Request */ type GetPipelineVersionTemplateParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_responses.go index e4717b3ba14..0436ff1d332 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_pipeline_version_template_responses.go @@ -49,7 +49,8 @@ func NewGetPipelineVersionTemplateOK() *GetPipelineVersionTemplateOK { return &GetPipelineVersionTemplateOK{} } -/*GetPipelineVersionTemplateOK handles this case with default header values. +/* +GetPipelineVersionTemplateOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetPipelineVersionTemplateDefault(code int) *GetPipelineVersionTemplateD } } -/*GetPipelineVersionTemplateDefault handles this case with default header values. +/* +GetPipelineVersionTemplateDefault handles this case with default header values. GetPipelineVersionTemplateDefault get pipeline version template default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_parameters.go index 684c1c11b96..d8e46da33bc 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_parameters.go @@ -56,7 +56,8 @@ func NewGetTemplateParamsWithHTTPClient(client *http.Client) *GetTemplateParams } } -/*GetTemplateParams contains all the parameters to send to the API endpoint +/* +GetTemplateParams contains all the parameters to send to the API endpoint for the get template operation typically these are written to a http.Request */ type GetTemplateParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_responses.go index 0bbab19faa6..9ec66ad789a 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/get_template_responses.go @@ -49,7 +49,8 @@ func NewGetTemplateOK() *GetTemplateOK { return &GetTemplateOK{} } -/*GetTemplateOK handles this case with default header values. +/* +GetTemplateOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetTemplateDefault(code int) *GetTemplateDefault { } } -/*GetTemplateDefault handles this case with default header values. +/* +GetTemplateDefault handles this case with default header values. GetTemplateDefault get template default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_parameters.go index e47bb7b8450..d916768a493 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_parameters.go @@ -69,7 +69,8 @@ func NewListPipelineVersionsParamsWithHTTPClient(client *http.Client) *ListPipel } } -/*ListPipelineVersionsParams contains all the parameters to send to the API endpoint +/* +ListPipelineVersionsParams contains all the parameters to send to the API endpoint for the list pipeline versions operation typically these are written to a http.Request */ type ListPipelineVersionsParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_responses.go index dbbf1b53c4b..9facc7aba17 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipeline_versions_responses.go @@ -49,7 +49,8 @@ func NewListPipelineVersionsOK() *ListPipelineVersionsOK { return &ListPipelineVersionsOK{} } -/*ListPipelineVersionsOK handles this case with default header values. +/* +ListPipelineVersionsOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewListPipelineVersionsDefault(code int) *ListPipelineVersionsDefault { } } -/*ListPipelineVersionsDefault handles this case with default header values. +/* +ListPipelineVersionsDefault handles this case with default header values. ListPipelineVersionsDefault list pipeline versions default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_parameters.go index 2cea7960543..66b4d51647f 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_parameters.go @@ -69,7 +69,8 @@ func NewListPipelinesParamsWithHTTPClient(client *http.Client) *ListPipelinesPar } } -/*ListPipelinesParams contains all the parameters to send to the API endpoint +/* +ListPipelinesParams contains all the parameters to send to the API endpoint for the list pipelines operation typically these are written to a http.Request */ type ListPipelinesParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_responses.go index 20597ff6ee0..7c092fa71d0 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/list_pipelines_responses.go @@ -49,7 +49,8 @@ func NewListPipelinesOK() *ListPipelinesOK { return &ListPipelinesOK{} } -/*ListPipelinesOK handles this case with default header values. +/* +ListPipelinesOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewListPipelinesDefault(code int) *ListPipelinesDefault { } } -/*ListPipelinesDefault handles this case with default header values. +/* +ListPipelinesDefault handles this case with default header values. ListPipelinesDefault list pipelines default */ diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_parameters.go b/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_parameters.go index 9aa93ed2a95..0782e4c9f4f 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_parameters.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_parameters.go @@ -56,7 +56,8 @@ func NewUpdatePipelineDefaultVersionParamsWithHTTPClient(client *http.Client) *U } } -/*UpdatePipelineDefaultVersionParams contains all the parameters to send to the API endpoint +/* +UpdatePipelineDefaultVersionParams contains all the parameters to send to the API endpoint for the update pipeline default version operation typically these are written to a http.Request */ type UpdatePipelineDefaultVersionParams struct { diff --git a/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_responses.go b/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_responses.go index ab6680b313e..96b35ddea17 100644 --- a/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_responses.go +++ b/backend/api/go_http_client/pipeline_client/pipeline_service/update_pipeline_default_version_responses.go @@ -49,7 +49,8 @@ func NewUpdatePipelineDefaultVersionOK() *UpdatePipelineDefaultVersionOK { return &UpdatePipelineDefaultVersionOK{} } -/*UpdatePipelineDefaultVersionOK handles this case with default header values. +/* +UpdatePipelineDefaultVersionOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewUpdatePipelineDefaultVersionDefault(code int) *UpdatePipelineDefaultVers } } -/*UpdatePipelineDefaultVersionDefault handles this case with default header values. +/* +UpdatePipelineDefaultVersionDefault handles this case with default header values. UpdatePipelineDefaultVersionDefault update pipeline default version default */ diff --git a/backend/api/go_http_client/pipeline_model/protobuf_any.go b/backend/api/go_http_client/pipeline_model/protobuf_any.go index 10ecc3fe5a2..7226e059883 100644 --- a/backend/api/go_http_client/pipeline_model/protobuf_any.go +++ b/backend/api/go_http_client/pipeline_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_parameters.go b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_parameters.go index 8b36f7ff7df..d67dbce5b32 100644 --- a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_parameters.go +++ b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_parameters.go @@ -56,7 +56,8 @@ func NewUploadPipelineParamsWithHTTPClient(client *http.Client) *UploadPipelineP } } -/*UploadPipelineParams contains all the parameters to send to the API endpoint +/* +UploadPipelineParams contains all the parameters to send to the API endpoint for the upload pipeline operation typically these are written to a http.Request */ type UploadPipelineParams struct { diff --git a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go index 6b4b94defeb..a82eea2feb5 100644 --- a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go +++ b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_responses.go @@ -49,7 +49,8 @@ func NewUploadPipelineOK() *UploadPipelineOK { return &UploadPipelineOK{} } -/*UploadPipelineOK handles this case with default header values. +/* +UploadPipelineOK handles this case with default header values. UploadPipelineOK upload pipeline o k */ @@ -80,7 +81,8 @@ func NewUploadPipelineDefault(code int) *UploadPipelineDefault { } } -/*UploadPipelineDefault handles this case with default header values. +/* +UploadPipelineDefault handles this case with default header values. UploadPipelineDefault upload pipeline default */ diff --git a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go index 6a056609f74..ffd7370825e 100644 --- a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go +++ b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_parameters.go @@ -56,7 +56,8 @@ func NewUploadPipelineVersionParamsWithHTTPClient(client *http.Client) *UploadPi } } -/*UploadPipelineVersionParams contains all the parameters to send to the API endpoint +/* +UploadPipelineVersionParams contains all the parameters to send to the API endpoint for the upload pipeline version operation typically these are written to a http.Request */ type UploadPipelineVersionParams struct { diff --git a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go index 101e5bf05b3..a59f245d13c 100644 --- a/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go +++ b/backend/api/go_http_client/pipeline_upload_client/pipeline_upload_service/upload_pipeline_version_responses.go @@ -49,7 +49,8 @@ func NewUploadPipelineVersionOK() *UploadPipelineVersionOK { return &UploadPipelineVersionOK{} } -/*UploadPipelineVersionOK handles this case with default header values. +/* +UploadPipelineVersionOK handles this case with default header values. UploadPipelineVersionOK upload pipeline version o k */ @@ -80,7 +81,8 @@ func NewUploadPipelineVersionDefault(code int) *UploadPipelineVersionDefault { } } -/*UploadPipelineVersionDefault handles this case with default header values. +/* +UploadPipelineVersionDefault handles this case with default header values. UploadPipelineVersionDefault upload pipeline version default */ diff --git a/backend/api/go_http_client/pipeline_upload_model/protobuf_any.go b/backend/api/go_http_client/pipeline_upload_model/protobuf_any.go index 80a4d4cd71f..f6e4370e439 100644 --- a/backend/api/go_http_client/pipeline_upload_model/protobuf_any.go +++ b/backend/api/go_http_client/pipeline_upload_model/protobuf_any.go @@ -20,42 +20,42 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := ptypes.MarshalAny(foo) -// ... -// foo := &pb.Foo{} -// if err := ptypes.UnmarshalAny(any, foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := ptypes.MarshalAny(foo) +// ... +// foo := &pb.Foo{} +// if err := ptypes.UnmarshalAny(any, foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -63,34 +63,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/run_client/run_service/archive_run_parameters.go b/backend/api/go_http_client/run_client/run_service/archive_run_parameters.go index 71672a67d87..9122636b2b8 100644 --- a/backend/api/go_http_client/run_client/run_service/archive_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/archive_run_parameters.go @@ -56,7 +56,8 @@ func NewArchiveRunParamsWithHTTPClient(client *http.Client) *ArchiveRunParams { } } -/*ArchiveRunParams contains all the parameters to send to the API endpoint +/* +ArchiveRunParams contains all the parameters to send to the API endpoint for the archive run operation typically these are written to a http.Request */ type ArchiveRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/archive_run_responses.go b/backend/api/go_http_client/run_client/run_service/archive_run_responses.go index cdcdd5939a8..c372e90b6b1 100644 --- a/backend/api/go_http_client/run_client/run_service/archive_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/archive_run_responses.go @@ -49,7 +49,8 @@ func NewArchiveRunOK() *ArchiveRunOK { return &ArchiveRunOK{} } -/*ArchiveRunOK handles this case with default header values. +/* +ArchiveRunOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewArchiveRunDefault(code int) *ArchiveRunDefault { } } -/*ArchiveRunDefault handles this case with default header values. +/* +ArchiveRunDefault handles this case with default header values. ArchiveRunDefault archive run default */ diff --git a/backend/api/go_http_client/run_client/run_service/create_run_parameters.go b/backend/api/go_http_client/run_client/run_service/create_run_parameters.go index 30c26f56b7b..0fb8f60dcb0 100644 --- a/backend/api/go_http_client/run_client/run_service/create_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/create_run_parameters.go @@ -58,7 +58,8 @@ func NewCreateRunParamsWithHTTPClient(client *http.Client) *CreateRunParams { } } -/*CreateRunParams contains all the parameters to send to the API endpoint +/* +CreateRunParams contains all the parameters to send to the API endpoint for the create run operation typically these are written to a http.Request */ type CreateRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/create_run_responses.go b/backend/api/go_http_client/run_client/run_service/create_run_responses.go index 1ebb6e9af09..8e6a09c166f 100644 --- a/backend/api/go_http_client/run_client/run_service/create_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/create_run_responses.go @@ -49,7 +49,8 @@ func NewCreateRunOK() *CreateRunOK { return &CreateRunOK{} } -/*CreateRunOK handles this case with default header values. +/* +CreateRunOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreateRunDefault(code int) *CreateRunDefault { } } -/*CreateRunDefault handles this case with default header values. +/* +CreateRunDefault handles this case with default header values. CreateRunDefault create run default */ diff --git a/backend/api/go_http_client/run_client/run_service/delete_run_parameters.go b/backend/api/go_http_client/run_client/run_service/delete_run_parameters.go index baf7313f274..6e78c0a36bc 100644 --- a/backend/api/go_http_client/run_client/run_service/delete_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/delete_run_parameters.go @@ -56,7 +56,8 @@ func NewDeleteRunParamsWithHTTPClient(client *http.Client) *DeleteRunParams { } } -/*DeleteRunParams contains all the parameters to send to the API endpoint +/* +DeleteRunParams contains all the parameters to send to the API endpoint for the delete run operation typically these are written to a http.Request */ type DeleteRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/delete_run_responses.go b/backend/api/go_http_client/run_client/run_service/delete_run_responses.go index 3f4cb4a3a05..99400327607 100644 --- a/backend/api/go_http_client/run_client/run_service/delete_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/delete_run_responses.go @@ -49,7 +49,8 @@ func NewDeleteRunOK() *DeleteRunOK { return &DeleteRunOK{} } -/*DeleteRunOK handles this case with default header values. +/* +DeleteRunOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewDeleteRunDefault(code int) *DeleteRunDefault { } } -/*DeleteRunDefault handles this case with default header values. +/* +DeleteRunDefault handles this case with default header values. DeleteRunDefault delete run default */ diff --git a/backend/api/go_http_client/run_client/run_service/get_run_parameters.go b/backend/api/go_http_client/run_client/run_service/get_run_parameters.go index acbd617e1c8..7d6cb864508 100644 --- a/backend/api/go_http_client/run_client/run_service/get_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/get_run_parameters.go @@ -56,7 +56,8 @@ func NewGetRunParamsWithHTTPClient(client *http.Client) *GetRunParams { } } -/*GetRunParams contains all the parameters to send to the API endpoint +/* +GetRunParams contains all the parameters to send to the API endpoint for the get run operation typically these are written to a http.Request */ type GetRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/get_run_responses.go b/backend/api/go_http_client/run_client/run_service/get_run_responses.go index daeec511fe4..a751f3d705b 100644 --- a/backend/api/go_http_client/run_client/run_service/get_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/get_run_responses.go @@ -49,7 +49,8 @@ func NewGetRunOK() *GetRunOK { return &GetRunOK{} } -/*GetRunOK handles this case with default header values. +/* +GetRunOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewGetRunDefault(code int) *GetRunDefault { } } -/*GetRunDefault handles this case with default header values. +/* +GetRunDefault handles this case with default header values. GetRunDefault get run default */ diff --git a/backend/api/go_http_client/run_client/run_service/list_runs_parameters.go b/backend/api/go_http_client/run_client/run_service/list_runs_parameters.go index bc9f248f0d9..0361de031cd 100644 --- a/backend/api/go_http_client/run_client/run_service/list_runs_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/list_runs_parameters.go @@ -69,7 +69,8 @@ func NewListRunsParamsWithHTTPClient(client *http.Client) *ListRunsParams { } } -/*ListRunsParams contains all the parameters to send to the API endpoint +/* +ListRunsParams contains all the parameters to send to the API endpoint for the list runs operation typically these are written to a http.Request */ type ListRunsParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/list_runs_responses.go b/backend/api/go_http_client/run_client/run_service/list_runs_responses.go index e5bb11ee4ce..9761d147755 100644 --- a/backend/api/go_http_client/run_client/run_service/list_runs_responses.go +++ b/backend/api/go_http_client/run_client/run_service/list_runs_responses.go @@ -49,7 +49,8 @@ func NewListRunsOK() *ListRunsOK { return &ListRunsOK{} } -/*ListRunsOK handles this case with default header values. +/* +ListRunsOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewListRunsDefault(code int) *ListRunsDefault { } } -/*ListRunsDefault handles this case with default header values. +/* +ListRunsDefault handles this case with default header values. ListRunsDefault list runs default */ diff --git a/backend/api/go_http_client/run_client/run_service/read_artifact_parameters.go b/backend/api/go_http_client/run_client/run_service/read_artifact_parameters.go index 8e7243ea313..bacd09706f0 100644 --- a/backend/api/go_http_client/run_client/run_service/read_artifact_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/read_artifact_parameters.go @@ -56,7 +56,8 @@ func NewReadArtifactParamsWithHTTPClient(client *http.Client) *ReadArtifactParam } } -/*ReadArtifactParams contains all the parameters to send to the API endpoint +/* +ReadArtifactParams contains all the parameters to send to the API endpoint for the read artifact operation typically these are written to a http.Request */ type ReadArtifactParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/read_artifact_responses.go b/backend/api/go_http_client/run_client/run_service/read_artifact_responses.go index ea87f9b42b3..4cd1dbaa692 100644 --- a/backend/api/go_http_client/run_client/run_service/read_artifact_responses.go +++ b/backend/api/go_http_client/run_client/run_service/read_artifact_responses.go @@ -49,7 +49,8 @@ func NewReadArtifactOK() *ReadArtifactOK { return &ReadArtifactOK{} } -/*ReadArtifactOK handles this case with default header values. +/* +ReadArtifactOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewReadArtifactDefault(code int) *ReadArtifactDefault { } } -/*ReadArtifactDefault handles this case with default header values. +/* +ReadArtifactDefault handles this case with default header values. ReadArtifactDefault read artifact default */ diff --git a/backend/api/go_http_client/run_client/run_service/report_run_metrics_parameters.go b/backend/api/go_http_client/run_client/run_service/report_run_metrics_parameters.go index c795f7fcc24..06671aea7e2 100644 --- a/backend/api/go_http_client/run_client/run_service/report_run_metrics_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/report_run_metrics_parameters.go @@ -58,7 +58,8 @@ func NewReportRunMetricsParamsWithHTTPClient(client *http.Client) *ReportRunMetr } } -/*ReportRunMetricsParams contains all the parameters to send to the API endpoint +/* +ReportRunMetricsParams contains all the parameters to send to the API endpoint for the report run metrics operation typically these are written to a http.Request */ type ReportRunMetricsParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/report_run_metrics_responses.go b/backend/api/go_http_client/run_client/run_service/report_run_metrics_responses.go index f17fedee98a..fd87a719053 100644 --- a/backend/api/go_http_client/run_client/run_service/report_run_metrics_responses.go +++ b/backend/api/go_http_client/run_client/run_service/report_run_metrics_responses.go @@ -49,7 +49,8 @@ func NewReportRunMetricsOK() *ReportRunMetricsOK { return &ReportRunMetricsOK{} } -/*ReportRunMetricsOK handles this case with default header values. +/* +ReportRunMetricsOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewReportRunMetricsDefault(code int) *ReportRunMetricsDefault { } } -/*ReportRunMetricsDefault handles this case with default header values. +/* +ReportRunMetricsDefault handles this case with default header values. ReportRunMetricsDefault report run metrics default */ diff --git a/backend/api/go_http_client/run_client/run_service/retry_run_parameters.go b/backend/api/go_http_client/run_client/run_service/retry_run_parameters.go index 88fb51cb66b..50ed5ded6d3 100644 --- a/backend/api/go_http_client/run_client/run_service/retry_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/retry_run_parameters.go @@ -56,7 +56,8 @@ func NewRetryRunParamsWithHTTPClient(client *http.Client) *RetryRunParams { } } -/*RetryRunParams contains all the parameters to send to the API endpoint +/* +RetryRunParams contains all the parameters to send to the API endpoint for the retry run operation typically these are written to a http.Request */ type RetryRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/retry_run_responses.go b/backend/api/go_http_client/run_client/run_service/retry_run_responses.go index d244875fb7c..4eb4fc1fceb 100644 --- a/backend/api/go_http_client/run_client/run_service/retry_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/retry_run_responses.go @@ -49,7 +49,8 @@ func NewRetryRunOK() *RetryRunOK { return &RetryRunOK{} } -/*RetryRunOK handles this case with default header values. +/* +RetryRunOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewRetryRunDefault(code int) *RetryRunDefault { } } -/*RetryRunDefault handles this case with default header values. +/* +RetryRunDefault handles this case with default header values. RetryRunDefault retry run default */ diff --git a/backend/api/go_http_client/run_client/run_service/terminate_run_parameters.go b/backend/api/go_http_client/run_client/run_service/terminate_run_parameters.go index 97352266ca0..b23b16d41a0 100644 --- a/backend/api/go_http_client/run_client/run_service/terminate_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/terminate_run_parameters.go @@ -56,7 +56,8 @@ func NewTerminateRunParamsWithHTTPClient(client *http.Client) *TerminateRunParam } } -/*TerminateRunParams contains all the parameters to send to the API endpoint +/* +TerminateRunParams contains all the parameters to send to the API endpoint for the terminate run operation typically these are written to a http.Request */ type TerminateRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/terminate_run_responses.go b/backend/api/go_http_client/run_client/run_service/terminate_run_responses.go index d70d8c5ecb0..0199e896f07 100644 --- a/backend/api/go_http_client/run_client/run_service/terminate_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/terminate_run_responses.go @@ -49,7 +49,8 @@ func NewTerminateRunOK() *TerminateRunOK { return &TerminateRunOK{} } -/*TerminateRunOK handles this case with default header values. +/* +TerminateRunOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewTerminateRunDefault(code int) *TerminateRunDefault { } } -/*TerminateRunDefault handles this case with default header values. +/* +TerminateRunDefault handles this case with default header values. TerminateRunDefault terminate run default */ diff --git a/backend/api/go_http_client/run_client/run_service/unarchive_run_parameters.go b/backend/api/go_http_client/run_client/run_service/unarchive_run_parameters.go index a6c1879d492..9299c86fb15 100644 --- a/backend/api/go_http_client/run_client/run_service/unarchive_run_parameters.go +++ b/backend/api/go_http_client/run_client/run_service/unarchive_run_parameters.go @@ -56,7 +56,8 @@ func NewUnarchiveRunParamsWithHTTPClient(client *http.Client) *UnarchiveRunParam } } -/*UnarchiveRunParams contains all the parameters to send to the API endpoint +/* +UnarchiveRunParams contains all the parameters to send to the API endpoint for the unarchive run operation typically these are written to a http.Request */ type UnarchiveRunParams struct { diff --git a/backend/api/go_http_client/run_client/run_service/unarchive_run_responses.go b/backend/api/go_http_client/run_client/run_service/unarchive_run_responses.go index 3d4bf2912b0..392ff8ab7a5 100644 --- a/backend/api/go_http_client/run_client/run_service/unarchive_run_responses.go +++ b/backend/api/go_http_client/run_client/run_service/unarchive_run_responses.go @@ -49,7 +49,8 @@ func NewUnarchiveRunOK() *UnarchiveRunOK { return &UnarchiveRunOK{} } -/*UnarchiveRunOK handles this case with default header values. +/* +UnarchiveRunOK handles this case with default header values. A successful response. */ @@ -78,7 +79,8 @@ func NewUnarchiveRunDefault(code int) *UnarchiveRunDefault { } } -/*UnarchiveRunDefault handles this case with default header values. +/* +UnarchiveRunDefault handles this case with default header values. UnarchiveRunDefault unarchive run default */ diff --git a/backend/api/go_http_client/run_model/protobuf_any.go b/backend/api/go_http_client/run_model/protobuf_any.go index 6d18c719ed8..952c4485d94 100644 --- a/backend/api/go_http_client/run_model/protobuf_any.go +++ b/backend/api/go_http_client/run_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/api/go_http_client/run_model/protobuf_null_value.go b/backend/api/go_http_client/run_model/protobuf_null_value.go index 852386abfff..644e217721b 100644 --- a/backend/api/go_http_client/run_model/protobuf_null_value.go +++ b/backend/api/go_http_client/run_model/protobuf_null_value.go @@ -17,9 +17,10 @@ import ( // ProtobufNullValue `NullValue` is a singleton enumeration to represent the null value for the // `Value` type union. // -// The JSON representation for `NullValue` is JSON `null`. +// The JSON representation for `NullValue` is JSON `null`. +// +// - NULL_VALUE: Null value. // -// - NULL_VALUE: Null value. // swagger:model protobufNullValue type ProtobufNullValue string diff --git a/backend/api/go_http_client/run_model/report_run_metrics_response_report_run_metric_result_status.go b/backend/api/go_http_client/run_model/report_run_metrics_response_report_run_metric_result_status.go index 19f00402eea..d8bc93b1c10 100644 --- a/backend/api/go_http_client/run_model/report_run_metrics_response_report_run_metric_result_status.go +++ b/backend/api/go_http_client/run_model/report_run_metrics_response_report_run_metric_result_status.go @@ -15,10 +15,11 @@ import ( ) // ReportRunMetricsResponseReportRunMetricResultStatus - UNSPECIFIED: Default value if not present. -// - OK: Indicates successful reporting. -// - INVALID_ARGUMENT: Indicates that the payload of the metric is invalid. -// - DUPLICATE_REPORTING: Indicates that the metric has been reported before. -// - INTERNAL_ERROR: Indicates that something went wrong in the server. +// - OK: Indicates successful reporting. +// - INVALID_ARGUMENT: Indicates that the payload of the metric is invalid. +// - DUPLICATE_REPORTING: Indicates that the metric has been reported before. +// - INTERNAL_ERROR: Indicates that something went wrong in the server. +// // swagger:model ReportRunMetricsResponseReportRunMetricResultStatus type ReportRunMetricsResponseReportRunMetricResultStatus string diff --git a/backend/api/go_http_client/run_model/run_metric_format.go b/backend/api/go_http_client/run_model/run_metric_format.go index 6a194f501b0..da5daeb6276 100644 --- a/backend/api/go_http_client/run_model/run_metric_format.go +++ b/backend/api/go_http_client/run_model/run_metric_format.go @@ -15,8 +15,9 @@ import ( ) // RunMetricFormat - UNSPECIFIED: Default value if not present. -// - RAW: Display value as its raw format. -// - PERCENTAGE: Display value in percentage format. +// - RAW: Display value as its raw format. +// - PERCENTAGE: Display value in percentage format. +// // swagger:model RunMetricFormat type RunMetricFormat string diff --git a/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_parameters.go b/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_parameters.go index fe526648845..744d327e6b7 100644 --- a/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_parameters.go +++ b/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_parameters.go @@ -58,7 +58,8 @@ func NewCreateVisualizationParamsWithHTTPClient(client *http.Client) *CreateVisu } } -/*CreateVisualizationParams contains all the parameters to send to the API endpoint +/* +CreateVisualizationParams contains all the parameters to send to the API endpoint for the create visualization operation typically these are written to a http.Request */ type CreateVisualizationParams struct { diff --git a/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_responses.go b/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_responses.go index 935e0d00c9a..2ae11032ecd 100644 --- a/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_responses.go +++ b/backend/api/go_http_client/visualization_client/visualization_service/create_visualization_responses.go @@ -49,7 +49,8 @@ func NewCreateVisualizationOK() *CreateVisualizationOK { return &CreateVisualizationOK{} } -/*CreateVisualizationOK handles this case with default header values. +/* +CreateVisualizationOK handles this case with default header values. A successful response. */ @@ -80,7 +81,8 @@ func NewCreateVisualizationDefault(code int) *CreateVisualizationDefault { } } -/*CreateVisualizationDefault handles this case with default header values. +/* +CreateVisualizationDefault handles this case with default header values. CreateVisualizationDefault create visualization default */ diff --git a/backend/api/go_http_client/visualization_model/protobuf_any.go b/backend/api/go_http_client/visualization_model/protobuf_any.go index a8f3909206e..fb338a59c98 100644 --- a/backend/api/go_http_client/visualization_model/protobuf_any.go +++ b/backend/api/go_http_client/visualization_model/protobuf_any.go @@ -20,45 +20,45 @@ import ( // // Example 1: Pack and unpack a message in C++. // -// Foo foo = ...; -// Any any; -// any.PackFrom(foo); -// ... -// if (any.UnpackTo(&foo)) { -// ... -// } +// Foo foo = ...; +// Any any; +// any.PackFrom(foo); +// ... +// if (any.UnpackTo(&foo)) { +// ... +// } // // Example 2: Pack and unpack a message in Java. // -// Foo foo = ...; -// Any any = Any.pack(foo); -// ... -// if (any.is(Foo.class)) { -// foo = any.unpack(Foo.class); -// } -// -// Example 3: Pack and unpack a message in Python. -// -// foo = Foo(...) -// any = Any() -// any.Pack(foo) -// ... -// if any.Is(Foo.DESCRIPTOR): -// any.Unpack(foo) -// ... -// -// Example 4: Pack and unpack a message in Go -// -// foo := &pb.Foo{...} -// any, err := anypb.New(foo) -// if err != nil { -// ... -// } -// ... -// foo := &pb.Foo{} -// if err := any.UnmarshalTo(foo); err != nil { -// ... -// } +// Foo foo = ...; +// Any any = Any.pack(foo); +// ... +// if (any.is(Foo.class)) { +// foo = any.unpack(Foo.class); +// } +// +// Example 3: Pack and unpack a message in Python. +// +// foo = Foo(...) +// any = Any() +// any.Pack(foo) +// ... +// if any.Is(Foo.DESCRIPTOR): +// any.Unpack(foo) +// ... +// +// Example 4: Pack and unpack a message in Go +// +// foo := &pb.Foo{...} +// any, err := anypb.New(foo) +// if err != nil { +// ... +// } +// ... +// foo := &pb.Foo{} +// if err := any.UnmarshalTo(foo); err != nil { +// ... +// } // // The pack methods provided by protobuf library will by default use // 'type.googleapis.com/full.type.name' as the type URL and the unpack @@ -66,34 +66,34 @@ import ( // in the type URL, for example "foo.bar.com/x/y.z" will yield type // name "y.z". // -// // JSON // ==== // The JSON representation of an `Any` value uses the regular // representation of the deserialized, embedded message, with an // additional field `@type` which contains the type URL. Example: // -// package google.profile; -// message Person { -// string first_name = 1; -// string last_name = 2; -// } +// package google.profile; +// message Person { +// string first_name = 1; +// string last_name = 2; +// } // -// { -// "@type": "type.googleapis.com/google.profile.Person", -// "firstName": , -// "lastName": -// } +// { +// "@type": "type.googleapis.com/google.profile.Person", +// "firstName": , +// "lastName": +// } // // If the embedded message type is well-known and has a custom JSON // representation, that representation will be embedded adding a field // `value` which holds the custom JSON in addition to the `@type` // field. Example (for message [google.protobuf.Duration][]): // -// { -// "@type": "type.googleapis.com/google.protobuf.Duration", -// "value": "1.212s" -// } +// { +// "@type": "type.googleapis.com/google.protobuf.Duration", +// "value": "1.212s" +// } +// // swagger:model protobufAny type ProtobufAny struct { diff --git a/backend/src/agent/persistence/worker/metrics_reporter_test.go b/backend/src/agent/persistence/worker/metrics_reporter_test.go index 35a0db5b9f4..8890988936c 100644 --- a/backend/src/agent/persistence/worker/metrics_reporter_test.go +++ b/backend/src/agent/persistence/worker/metrics_reporter_test.go @@ -197,7 +197,7 @@ func TestReportMetrics_Succeed(t *testing.T) { got := pipelineFake.GetReportedMetricsRequest() if diff := cmp.Diff(expectedMetricsRequest, got, cmpopts.EquateEmpty(), protocmp.Transform()); diff != "" { t.Errorf("parseRuntimeInfo() = %+v, want %+v\nDiff (-want, +got)\n%s", got, expectedMetricsRequest, diff) - s, _ := json.MarshalIndent(expectedMetricsRequest ,"", " ") + s, _ := json.MarshalIndent(expectedMetricsRequest, "", " ") fmt.Printf("Want %s", s) } } @@ -404,7 +404,7 @@ func TestReportMetrics_InvalidMetricsJSON_PartialFail(t *testing.T) { got := pipelineFake.GetReportedMetricsRequest() if diff := cmp.Diff(expectedMetricsRequest, got, cmpopts.EquateEmpty(), protocmp.Transform()); diff != "" { t.Errorf("parseRuntimeInfo() = %+v, want %+v\nDiff (-want, +got)\n%s", got, expectedMetricsRequest, diff) - s, _ := json.MarshalIndent(expectedMetricsRequest ,"", " ") + s, _ := json.MarshalIndent(expectedMetricsRequest, "", " ") fmt.Printf("Want %s", s) } } diff --git a/backend/src/agent/persistence/worker/workflow_saver.go b/backend/src/agent/persistence/worker/workflow_saver.go index 9635d020194..64958dc5791 100644 --- a/backend/src/agent/persistence/worker/workflow_saver.go +++ b/backend/src/agent/persistence/worker/workflow_saver.go @@ -31,7 +31,7 @@ type WorkflowSaver struct { } func NewWorkflowSaver(client client.WorkflowClientInterface, - pipelineClient client.PipelineClientInterface, ttlSecondsAfterWorkflowFinish int64) *WorkflowSaver { + pipelineClient client.PipelineClientInterface, ttlSecondsAfterWorkflowFinish int64) *WorkflowSaver { return &WorkflowSaver{ client: client, pipelineClient: pipelineClient, diff --git a/backend/src/apiserver/archive/log.go b/backend/src/apiserver/archive/log.go index 604d2bed653..10af8321825 100644 --- a/backend/src/apiserver/archive/log.go +++ b/backend/src/apiserver/archive/log.go @@ -54,182 +54,183 @@ type RunLogEntry struct { // Inspired on fluent-bit parsers // https://github.com/fluent/fluent-bit/blob/master/tests/runtime/data/kubernetes/parsers.conf -// Apache License -// Version 2.0, January 2004 -// http://www.apache.org/licenses/ // -// TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION +// Apache License +// Version 2.0, January 2004 +// http://www.apache.org/licenses/ // -// 1. Definitions. +// TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION // -// "License" shall mean the terms and conditions for use, reproduction, -// and distribution as defined by Sections 1 through 9 of this document. +// 1. Definitions. // -// "Licensor" shall mean the copyright owner or entity authorized by -// the copyright owner that is granting the License. +// "License" shall mean the terms and conditions for use, reproduction, +// and distribution as defined by Sections 1 through 9 of this document. // -// "Legal Entity" shall mean the union of the acting entity and all -// other entities that control, are controlled by, or are under common -// control with that entity. For the purposes of this definition, -// "control" means (i) the power, direct or indirect, to cause the -// direction or management of such entity, whether by contract or -// otherwise, or (ii) ownership of fifty percent (50%) or more of the -// outstanding shares, or (iii) beneficial ownership of such entity. +// "Licensor" shall mean the copyright owner or entity authorized by +// the copyright owner that is granting the License. // -// "You" (or "Your") shall mean an individual or Legal Entity -// exercising permissions granted by this License. +// "Legal Entity" shall mean the union of the acting entity and all +// other entities that control, are controlled by, or are under common +// control with that entity. For the purposes of this definition, +// "control" means (i) the power, direct or indirect, to cause the +// direction or management of such entity, whether by contract or +// otherwise, or (ii) ownership of fifty percent (50%) or more of the +// outstanding shares, or (iii) beneficial ownership of such entity. // -// "Source" form shall mean the preferred form for making modifications, -// including but not limited to software source code, documentation -// source, and configuration files. +// "You" (or "Your") shall mean an individual or Legal Entity +// exercising permissions granted by this License. // -// "Object" form shall mean any form resulting from mechanical -// transformation or translation of a Source form, including but -// not limited to compiled object code, generated documentation, -// and conversions to other media types. +// "Source" form shall mean the preferred form for making modifications, +// including but not limited to software source code, documentation +// source, and configuration files. // -// "Work" shall mean the work of authorship, whether in Source or -// Object form, made available under the License, as indicated by a -// copyright notice that is included in or attached to the work -// (an example is provided in the Appendix below). +// "Object" form shall mean any form resulting from mechanical +// transformation or translation of a Source form, including but +// not limited to compiled object code, generated documentation, +// and conversions to other media types. // -// "Derivative Works" shall mean any work, whether in Source or Object -// form, that is based on (or derived from) the Work and for which the -// editorial revisions, annotations, elaborations, or other modifications -// represent, as a whole, an original work of authorship. For the purposes -// of this License, Derivative Works shall not include works that remain -// separable from, or merely link (or bind by name) to the interfaces of, -// the Work and Derivative Works thereof. +// "Work" shall mean the work of authorship, whether in Source or +// Object form, made available under the License, as indicated by a +// copyright notice that is included in or attached to the work +// (an example is provided in the Appendix below). // -// "Contribution" shall mean any work of authorship, including -// the original version of the Work and any modifications or additions -// to that Work or Derivative Works thereof, that is intentionally -// submitted to Licensor for inclusion in the Work by the copyright owner -// or by an individual or Legal Entity authorized to submit on behalf of -// the copyright owner. For the purposes of this definition, "submitted" -// means any form of electronic, verbal, or written communication sent -// to the Licensor or its representatives, including but not limited to -// communication on electronic mailing lists, source code control systems, -// and issue tracking systems that are managed by, or on behalf of, the -// Licensor for the purpose of discussing and improving the Work, but -// excluding communication that is conspicuously marked or otherwise -// designated in writing by the copyright owner as "Not a Contribution." +// "Derivative Works" shall mean any work, whether in Source or Object +// form, that is based on (or derived from) the Work and for which the +// editorial revisions, annotations, elaborations, or other modifications +// represent, as a whole, an original work of authorship. For the purposes +// of this License, Derivative Works shall not include works that remain +// separable from, or merely link (or bind by name) to the interfaces of, +// the Work and Derivative Works thereof. // -// "Contributor" shall mean Licensor and any individual or Legal Entity -// on behalf of whom a Contribution has been received by Licensor and -// subsequently incorporated within the Work. +// "Contribution" shall mean any work of authorship, including +// the original version of the Work and any modifications or additions +// to that Work or Derivative Works thereof, that is intentionally +// submitted to Licensor for inclusion in the Work by the copyright owner +// or by an individual or Legal Entity authorized to submit on behalf of +// the copyright owner. For the purposes of this definition, "submitted" +// means any form of electronic, verbal, or written communication sent +// to the Licensor or its representatives, including but not limited to +// communication on electronic mailing lists, source code control systems, +// and issue tracking systems that are managed by, or on behalf of, the +// Licensor for the purpose of discussing and improving the Work, but +// excluding communication that is conspicuously marked or otherwise +// designated in writing by the copyright owner as "Not a Contribution." // -// 2. Grant of Copyright License. Subject to the terms and conditions of -// this License, each Contributor hereby grants to You a perpetual, -// worldwide, non-exclusive, no-charge, royalty-free, irrevocable -// copyright license to reproduce, prepare Derivative Works of, -// publicly display, publicly perform, sublicense, and distribute the -// Work and such Derivative Works in Source or Object form. +// "Contributor" shall mean Licensor and any individual or Legal Entity +// on behalf of whom a Contribution has been received by Licensor and +// subsequently incorporated within the Work. // -// 3. Grant of Patent License. Subject to the terms and conditions of -// this License, each Contributor hereby grants to You a perpetual, -// worldwide, non-exclusive, no-charge, royalty-free, irrevocable -// (except as stated in this section) patent license to make, have made, -// use, offer to sell, sell, import, and otherwise transfer the Work, -// where such license applies only to those patent claims licensable -// by such Contributor that are necessarily infringed by their -// Contribution(s) alone or by combination of their Contribution(s) -// with the Work to which such Contribution(s) was submitted. If You -// institute patent litigation against any entity (including a -// cross-claim or counterclaim in a lawsuit) alleging that the Work -// or a Contribution incorporated within the Work constitutes direct -// or contributory patent infringement, then any patent licenses -// granted to You under this License for that Work shall terminate -// as of the date such litigation is filed. +// 2. Grant of Copyright License. Subject to the terms and conditions of +// this License, each Contributor hereby grants to You a perpetual, +// worldwide, non-exclusive, no-charge, royalty-free, irrevocable +// copyright license to reproduce, prepare Derivative Works of, +// publicly display, publicly perform, sublicense, and distribute the +// Work and such Derivative Works in Source or Object form. // -// 4. Redistribution. You may reproduce and distribute copies of the -// Work or Derivative Works thereof in any medium, with or without -// modifications, and in Source or Object form, provided that You -// meet the following conditions: +// 3. Grant of Patent License. Subject to the terms and conditions of +// this License, each Contributor hereby grants to You a perpetual, +// worldwide, non-exclusive, no-charge, royalty-free, irrevocable +// (except as stated in this section) patent license to make, have made, +// use, offer to sell, sell, import, and otherwise transfer the Work, +// where such license applies only to those patent claims licensable +// by such Contributor that are necessarily infringed by their +// Contribution(s) alone or by combination of their Contribution(s) +// with the Work to which such Contribution(s) was submitted. If You +// institute patent litigation against any entity (including a +// cross-claim or counterclaim in a lawsuit) alleging that the Work +// or a Contribution incorporated within the Work constitutes direct +// or contributory patent infringement, then any patent licenses +// granted to You under this License for that Work shall terminate +// as of the date such litigation is filed. // -// (a) You must give any other recipients of the Work or -// Derivative Works a copy of this License; and +// 4. Redistribution. You may reproduce and distribute copies of the +// Work or Derivative Works thereof in any medium, with or without +// modifications, and in Source or Object form, provided that You +// meet the following conditions: // -// (b) You must cause any modified files to carry prominent notices -// stating that You changed the files; and +// (a) You must give any other recipients of the Work or +// Derivative Works a copy of this License; and // -// (c) You must retain, in the Source form of any Derivative Works -// that You distribute, all copyright, patent, trademark, and -// attribution notices from the Source form of the Work, -// excluding those notices that do not pertain to any part of -// the Derivative Works; and +// (b) You must cause any modified files to carry prominent notices +// stating that You changed the files; and // -// (d) If the Work includes a "NOTICE" text file as part of its -// distribution, then any Derivative Works that You distribute must -// include a readable copy of the attribution notices contained -// within such NOTICE file, excluding those notices that do not -// pertain to any part of the Derivative Works, in at least one -// of the following places: within a NOTICE text file distributed -// as part of the Derivative Works; within the Source form or -// documentation, if provided along with the Derivative Works; or, -// within a display generated by the Derivative Works, if and -// wherever such third-party notices normally appear. The contents -// of the NOTICE file are for informational purposes only and -// do not modify the License. You may add Your own attribution -// notices within Derivative Works that You distribute, alongside -// or as an addendum to the NOTICE text from the Work, provided -// that such additional attribution notices cannot be construed -// as modifying the License. +// (c) You must retain, in the Source form of any Derivative Works +// that You distribute, all copyright, patent, trademark, and +// attribution notices from the Source form of the Work, +// excluding those notices that do not pertain to any part of +// the Derivative Works; and // -// You may add Your own copyright statement to Your modifications and -// may provide additional or different license terms and conditions -// for use, reproduction, or distribution of Your modifications, or -// for any such Derivative Works as a whole, provided Your use, -// reproduction, and distribution of the Work otherwise complies with -// the conditions stated in this License. +// (d) If the Work includes a "NOTICE" text file as part of its +// distribution, then any Derivative Works that You distribute must +// include a readable copy of the attribution notices contained +// within such NOTICE file, excluding those notices that do not +// pertain to any part of the Derivative Works, in at least one +// of the following places: within a NOTICE text file distributed +// as part of the Derivative Works; within the Source form or +// documentation, if provided along with the Derivative Works; or, +// within a display generated by the Derivative Works, if and +// wherever such third-party notices normally appear. The contents +// of the NOTICE file are for informational purposes only and +// do not modify the License. You may add Your own attribution +// notices within Derivative Works that You distribute, alongside +// or as an addendum to the NOTICE text from the Work, provided +// that such additional attribution notices cannot be construed +// as modifying the License. // -// 5. Submission of Contributions. Unless You explicitly state otherwise, -// any Contribution intentionally submitted for inclusion in the Work -// by You to the Licensor shall be under the terms and conditions of -// this License, without any additional terms or conditions. -// Notwithstanding the above, nothing herein shall supersede or modify -// the terms of any separate license agreement you may have executed -// with Licensor regarding such Contributions. +// You may add Your own copyright statement to Your modifications and +// may provide additional or different license terms and conditions +// for use, reproduction, or distribution of Your modifications, or +// for any such Derivative Works as a whole, provided Your use, +// reproduction, and distribution of the Work otherwise complies with +// the conditions stated in this License. // -// 6. Trademarks. This License does not grant permission to use the trade -// names, trademarks, service marks, or product names of the Licensor, -// except as required for reasonable and customary use in describing the -// origin of the Work and reproducing the content of the NOTICE file. +// 5. Submission of Contributions. Unless You explicitly state otherwise, +// any Contribution intentionally submitted for inclusion in the Work +// by You to the Licensor shall be under the terms and conditions of +// this License, without any additional terms or conditions. +// Notwithstanding the above, nothing herein shall supersede or modify +// the terms of any separate license agreement you may have executed +// with Licensor regarding such Contributions. // -// 7. Disclaimer of Warranty. Unless required by applicable law or -// agreed to in writing, Licensor provides the Work (and each -// Contributor provides its Contributions) on an "AS IS" BASIS, -// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or -// implied, including, without limitation, any warranties or conditions -// of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A -// PARTICULAR PURPOSE. You are solely responsible for determining the -// appropriateness of using or redistributing the Work and assume any -// risks associated with Your exercise of permissions under this License. +// 6. Trademarks. This License does not grant permission to use the trade +// names, trademarks, service marks, or product names of the Licensor, +// except as required for reasonable and customary use in describing the +// origin of the Work and reproducing the content of the NOTICE file. // -// 8. Limitation of Liability. In no event and under no legal theory, -// whether in tort (including negligence), contract, or otherwise, -// unless required by applicable law (such as deliberate and grossly -// negligent acts) or agreed to in writing, shall any Contributor be -// liable to You for damages, including any direct, indirect, special, -// incidental, or consequential damages of any character arising as a -// result of this License or out of the use or inability to use the -// Work (including but not limited to damages for loss of goodwill, -// work stoppage, computer failure or malfunction, or any and all -// other commercial damages or losses), even if such Contributor -// has been advised of the possibility of such damages. +// 7. Disclaimer of Warranty. Unless required by applicable law or +// agreed to in writing, Licensor provides the Work (and each +// Contributor provides its Contributions) on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or +// implied, including, without limitation, any warranties or conditions +// of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A +// PARTICULAR PURPOSE. You are solely responsible for determining the +// appropriateness of using or redistributing the Work and assume any +// risks associated with Your exercise of permissions under this License. // -// 9. Accepting Warranty or Additional Liability. While redistributing -// the Work or Derivative Works thereof, You may choose to offer, -// and charge a fee for, acceptance of support, warranty, indemnity, -// or other liability obligations and/or rights consistent with this -// License. However, in accepting such obligations, You may act only -// on Your own behalf and on Your sole responsibility, not on behalf -// of any other Contributor, and only if You agree to indemnify, -// defend, and hold each Contributor harmless for any liability -// incurred by, or claims asserted against, such Contributor by reason -// of your accepting any such warranty or additional liability. +// 8. Limitation of Liability. In no event and under no legal theory, +// whether in tort (including negligence), contract, or otherwise, +// unless required by applicable law (such as deliberate and grossly +// negligent acts) or agreed to in writing, shall any Contributor be +// liable to You for damages, including any direct, indirect, special, +// incidental, or consequential damages of any character arising as a +// result of this License or out of the use or inability to use the +// Work (including but not limited to damages for loss of goodwill, +// work stoppage, computer failure or malfunction, or any and all +// other commercial damages or losses), even if such Contributor +// has been advised of the possibility of such damages. // -// END OF TERMS AND CONDITIONS +// 9. Accepting Warranty or Additional Liability. While redistributing +// the Work or Derivative Works thereof, You may choose to offer, +// and charge a fee for, acceptance of support, warranty, indemnity, +// or other liability obligations and/or rights consistent with this +// License. However, in accepting such obligations, You may act only +// on Your own behalf and on Your sole responsibility, not on behalf +// of any other Contributor, and only if You agree to indemnify, +// defend, and hold each Contributor harmless for any liability +// incurred by, or claims asserted against, such Contributor by reason +// of your accepting any such warranty or additional liability. +// +// END OF TERMS AND CONDITIONS var k8sLogPrefixExp = regexp.MustCompile(`(?m)^(\d{4}-\d{2}-\d{2}T\S+)\s(.+)$`) var crioLogPrefixExp = regexp.MustCompile(`(?m)^(.+)\s(stdout|stderr)\s\w\s(.+)$`) diff --git a/backend/src/apiserver/common/util.go b/backend/src/apiserver/common/util.go index ad6a54b4bfc..dde3ef5c115 100644 --- a/backend/src/apiserver/common/util.go +++ b/backend/src/apiserver/common/util.go @@ -18,12 +18,13 @@ import ( api "github.com/kubeflow/pipelines/backend/api/go_client" "strings" ) + const ( DefaultPipelineRunnerServiceAccount = "pipeline-runner" HasDefaultBucketEnvVar = "HAS_DEFAULT_BUCKET" DefaultBucketNameEnvVar = "BUCKET_NAME" - ProjectIDEnvVar = "PROJECT_ID" - ) + ProjectIDEnvVar = "PROJECT_ID" +) func GetNamespaceFromAPIResourceReferences(resourceRefs []*api.ResourceReference) string { namespace := "" @@ -49,7 +50,8 @@ func GetExperimentIDFromAPIResourceReferences(resourceRefs []*api.ResourceRefere // Mutate default values of specified pipeline spec. // Args: -// text: (part of) pipeline file in string. +// +// text: (part of) pipeline file in string. func PatchPipelineDefaultParameter(text string) (string, error) { defaultBucket := GetStringConfig(DefaultBucketNameEnvVar) projectId := GetStringConfig(ProjectIDEnvVar) diff --git a/backend/src/apiserver/filter/filter.go b/backend/src/apiserver/filter/filter.go index 2b27fb279a9..c5b7fff315a 100644 --- a/backend/src/apiserver/filter/filter.go +++ b/backend/src/apiserver/filter/filter.go @@ -139,7 +139,7 @@ func NewWithKeyMap(filterProto *api.Filter, keyMap map[string]string, modelName if modelName != "" { modelNamePrefix = modelName + "." } - + for _, pred := range filterProto.Predicates { k, ok := keyMap[pred.Key] if !ok { diff --git a/backend/src/apiserver/filter/filter_test.go b/backend/src/apiserver/filter/filter_test.go index 63180f1a947..6a5f0dfdfbd 100644 --- a/backend/src/apiserver/filter/filter_test.go +++ b/backend/src/apiserver/filter/filter_test.go @@ -348,7 +348,7 @@ func TestUnmarshalJSON(t *testing.T) { got := &Filter{} err := json.Unmarshal([]byte(in), got) - if err != nil || !cmp.Equal(got, want, cmpopts.EquateEmpty(), protocmp.Transform(),cmp.AllowUnexported(Filter{})) { + if err != nil || !cmp.Equal(got, want, cmpopts.EquateEmpty(), protocmp.Transform(), cmp.AllowUnexported(Filter{})) { t.Errorf("json.Unmarshal(%+v):\nGot: %v, Error: %v\nWant:\n%+v, Error: nil\nDiff:%s\n", in, got, err, want, cmp.Diff(want, got, cmp.AllowUnexported(Filter{}))) } } diff --git a/backend/src/apiserver/server/job_server_test.go b/backend/src/apiserver/server/job_server_test.go index 26de4dd0a62..c3ef91626ae 100644 --- a/backend/src/apiserver/server/job_server_test.go +++ b/backend/src/apiserver/server/job_server_test.go @@ -529,7 +529,7 @@ func TestListJobs_Multiuser(t *testing.T) { } else { if err != nil { t.Errorf("TestListJobs_Multiuser(%v) expect no error but got %v", tc.name, err) - } else if !cmp.Equal(tc.expectedJobs, response.Jobs, cmpopts.EquateEmpty(), protocmp.Transform(),cmpopts.IgnoreFields(api.Job{}, "Trigger", "UpdatedAt", "CreatedAt"), + } else if !cmp.Equal(tc.expectedJobs, response.Jobs, cmpopts.EquateEmpty(), protocmp.Transform(), cmpopts.IgnoreFields(api.Job{}, "Trigger", "UpdatedAt", "CreatedAt"), cmpopts.IgnoreFields(api.Run{}, "CreatedAt")) { t.Errorf("TestListJobs_Multiuser(%v) expect (%+v) but got (%+v)", tc.name, tc.expectedJobs, response.Jobs) } diff --git a/backend/src/apiserver/server/list_request_util_test.go b/backend/src/apiserver/server/list_request_util_test.go index 7b5cd1204d0..d61200f1275 100644 --- a/backend/src/apiserver/server/list_request_util_test.go +++ b/backend/src/apiserver/server/list_request_util_test.go @@ -213,7 +213,7 @@ func TestParseAPIFilter_DecodesEncodedString(t *testing.T) { } got, err := parseAPIFilter(in) - if !cmp.Equal(got, want, cmpopts.EquateEmpty(), protocmp.Transform(),) || err != nil { + if !cmp.Equal(got, want, cmpopts.EquateEmpty(), protocmp.Transform()) || err != nil { t.Errorf("parseAPIString(%q) =\nGot %+v, %v\n Want %+v, \nDiff: %s", in, got, err, want, cmp.Diff(want, got)) } diff --git a/backend/src/apiserver/server/util.go b/backend/src/apiserver/server/util.go index 6b6b6fab7ee..3124816ada9 100644 --- a/backend/src/apiserver/server/util.go +++ b/backend/src/apiserver/server/util.go @@ -15,6 +15,7 @@ import ( "github.com/kubeflow/pipelines/api/v2alpha1/go/pipelinespec" + "github.com/ghodss/yaml" "github.com/golang/glog" api "github.com/kubeflow/pipelines/backend/api/go_client" "github.com/kubeflow/pipelines/backend/src/apiserver/common" @@ -22,7 +23,6 @@ import ( "github.com/kubeflow/pipelines/backend/src/common/util" "github.com/pkg/errors" authorizationv1 "k8s.io/api/authorization/v1" - "github.com/ghodss/yaml" ) // These are valid conditions of a ScheduledWorkflow. diff --git a/backend/src/apiserver/storage/task_store.go b/backend/src/apiserver/storage/task_store.go index 5f436604168..344045eaf69 100644 --- a/backend/src/apiserver/storage/task_store.go +++ b/backend/src/apiserver/storage/task_store.go @@ -44,8 +44,8 @@ type TaskStore struct { // NewTaskStore creates a new TaskStore. func NewTaskStore(db *DB, time util.TimeInterface, uuid util.UUIDGeneratorInterface) *TaskStore { return &TaskStore{ - db: db, - time: time, + db: db, + time: time, uuid: uuid, } } @@ -62,14 +62,14 @@ func (s *TaskStore) CreateTask(task *model.Task) (*model.Task, error) { sql, args, err := sq. Insert(table_name). SetMap(sq.Eq{ - "UUID": newTask.UUID, - "Namespace": newTask.Namespace, - "PipelineName": newTask.PipelineName, - "RunUUID": newTask.RunUUID, - "MLMDExecutionID": newTask.MLMDExecutionID, - "CreatedTimestamp": newTask.CreatedTimestamp, - "FinishedTimestamp":newTask.FinishedTimestamp, - "Fingerprint": newTask.Fingerprint, + "UUID": newTask.UUID, + "Namespace": newTask.Namespace, + "PipelineName": newTask.PipelineName, + "RunUUID": newTask.RunUUID, + "MLMDExecutionID": newTask.MLMDExecutionID, + "CreatedTimestamp": newTask.CreatedTimestamp, + "FinishedTimestamp": newTask.FinishedTimestamp, + "Fingerprint": newTask.Fingerprint, }). ToSql() if err != nil { diff --git a/backend/src/common/util/execution_spec.go b/backend/src/common/util/execution_spec.go index 316dbe6e9b0..48be3258f28 100644 --- a/backend/src/common/util/execution_spec.go +++ b/backend/src/common/util/execution_spec.go @@ -46,8 +46,9 @@ type SpecParameters []SpecParameter // i.e Workflow is for Argo, PipelineRun is for Tekton and etc. // Status related information will go to ExecutionStatus interface. // TODO: add more methods to make ExecutionSpec fullly represent Workflow. At the beginning -// phase, gradually add methods and not break the existing functions. Later on, -// other execution runtime support could be added too. +// +// phase, gradually add methods and not break the existing functions. Later on, +// other execution runtime support could be added too. type ExecutionSpec interface { // ExecutionType ExecutionType() ExecutionType diff --git a/backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/zz_generated.deepcopy.go b/backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/zz_generated.deepcopy.go index e6d95b85ad1..00cccd189c9 100644 --- a/backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/zz_generated.deepcopy.go +++ b/backend/src/crd/pkg/apis/scheduledworkflow/v1beta1/zz_generated.deepcopy.go @@ -1,3 +1,4 @@ +//go:build !ignore_autogenerated // +build !ignore_autogenerated // Copyright 2018 The Kubeflow Authors diff --git a/backend/src/crd/pkg/apis/viewer/v1beta1/zz_generated.deepcopy.go b/backend/src/crd/pkg/apis/viewer/v1beta1/zz_generated.deepcopy.go index 295ed559918..dffef70267a 100644 --- a/backend/src/crd/pkg/apis/viewer/v1beta1/zz_generated.deepcopy.go +++ b/backend/src/crd/pkg/apis/viewer/v1beta1/zz_generated.deepcopy.go @@ -1,3 +1,4 @@ +//go:build !ignore_autogenerated // +build !ignore_autogenerated // Copyright 2018 The Kubeflow Authors diff --git a/backend/src/crd/pkg/client/clientset/versioned/fake/register.go b/backend/src/crd/pkg/client/clientset/versioned/fake/register.go index a59cf86c30f..4057c4ace95 100644 --- a/backend/src/crd/pkg/client/clientset/versioned/fake/register.go +++ b/backend/src/crd/pkg/client/clientset/versioned/fake/register.go @@ -34,14 +34,14 @@ var localSchemeBuilder = runtime.SchemeBuilder{ // AddToScheme adds all types of this clientset into the given scheme. This allows composition // of clientsets, like in: // -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) +// import ( +// "k8s.io/client-go/kubernetes" +// clientsetscheme "k8s.io/client-go/kubernetes/scheme" +// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" +// ) // -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) +// kclientset, _ := kubernetes.NewForConfig(c) +// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) // // After this, RawExtensions in Kubernetes types will serialize kube-aggregator types // correctly. diff --git a/backend/src/crd/pkg/client/clientset/versioned/scheme/register.go b/backend/src/crd/pkg/client/clientset/versioned/scheme/register.go index e770b68b1d2..bb298625a85 100644 --- a/backend/src/crd/pkg/client/clientset/versioned/scheme/register.go +++ b/backend/src/crd/pkg/client/clientset/versioned/scheme/register.go @@ -34,14 +34,14 @@ var localSchemeBuilder = runtime.SchemeBuilder{ // AddToScheme adds all types of this clientset into the given scheme. This allows composition // of clientsets, like in: // -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) +// import ( +// "k8s.io/client-go/kubernetes" +// clientsetscheme "k8s.io/client-go/kubernetes/scheme" +// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" +// ) // -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) +// kclientset, _ := kubernetes.NewForConfig(c) +// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) // // After this, RawExtensions in Kubernetes types will serialize kube-aggregator types // correctly. diff --git a/backend/src/v2/cmd/compiler/main.go b/backend/src/v2/cmd/compiler/main.go index 4d4a60e1bf2..ded499c2643 100644 --- a/backend/src/v2/cmd/compiler/main.go +++ b/backend/src/v2/cmd/compiler/main.go @@ -4,7 +4,7 @@ // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // -// http://www.apache.org/licenses/LICENSE-2.0 +// http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, diff --git a/backend/src/v2/cmd/driver/main.go b/backend/src/v2/cmd/driver/main.go index 797490da8fc..21294d292c0 100644 --- a/backend/src/v2/cmd/driver/main.go +++ b/backend/src/v2/cmd/driver/main.go @@ -4,7 +4,7 @@ // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // -// http://www.apache.org/licenses/LICENSE-2.0 +// http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, diff --git a/backend/src/v2/metadata/client.go b/backend/src/v2/metadata/client.go index a945a6cbc5c..246a709f6a4 100644 --- a/backend/src/v2/metadata/client.go +++ b/backend/src/v2/metadata/client.go @@ -847,7 +847,7 @@ func (c *Client) RecordArtifact(ctx context.Context, outputName, schema string, }, nil } -// TODO consider batching these requests +// TODO consider batching these requests func (c *Client) GetOrInsertArtifactType(ctx context.Context, schema string) (typeID int64, err error) { defer func() { if err != nil { diff --git a/third_party/ml-metadata/go/ml_metadata/metadata_store.pb.go b/third_party/ml-metadata/go/ml_metadata/metadata_store.pb.go index c2988f5e0c8..1089d0fc55b 100644 --- a/third_party/ml-metadata/go/ml_metadata/metadata_store.pb.go +++ b/third_party/ml-metadata/go/ml_metadata/metadata_store.pb.go @@ -316,7 +316,9 @@ func (Event_Type) EnumDescriptor() ([]byte, []int) { } // The state of the Execution. The state transitions are -// NEW -> RUNNING -> COMPLETE | CACHED | FAILED | CANCELED +// +// NEW -> RUNNING -> COMPLETE | CACHED | FAILED | CANCELED +// // CACHED means the execution is skipped due to cached results. // CANCELED means the execution is skipped due to precondition not met. It is // different from CACHED in that a CANCELED execution will not have any event @@ -1046,68 +1048,73 @@ func (x *ArtifactType) GetBaseType() ArtifactType_SystemDefinedBaseType { // For example, the DECLARED_INPUT and DECLARED_OUTPUT events are part of the // signature of an execution. For example, consider: // -// my_result = my_execution({"data":[3,7],"schema":8}) +// my_result = my_execution({"data":[3,7],"schema":8}) // // Where 3, 7, and 8 are artifact_ids, Assuming execution_id of my_execution is // 12 and artifact_id of my_result is 15, the events are: -// { -// artifact_id:3, -// execution_id: 12, -// type:DECLARED_INPUT, -// path:{step:[{"key":"data"},{"index":0}]} -// } -// { -// artifact_id:7, -// execution_id: 12, -// type:DECLARED_INPUT, -// path:{step:[{"key":"data"},{"index":1}]} -// } -// { -// artifact_id:8, -// execution_id: 12, -// type:DECLARED_INPUT, -// path:{step:[{"key":"schema"}]} -// } -// { -// artifact_id:15, -// execution_id: 12, -// type:DECLARED_OUTPUT, -// path:{step:[{"key":"my_result"}]} -// } +// +// { +// artifact_id:3, +// execution_id: 12, +// type:DECLARED_INPUT, +// path:{step:[{"key":"data"},{"index":0}]} +// } +// { +// artifact_id:7, +// execution_id: 12, +// type:DECLARED_INPUT, +// path:{step:[{"key":"data"},{"index":1}]} +// } +// { +// artifact_id:8, +// execution_id: 12, +// type:DECLARED_INPUT, +// path:{step:[{"key":"schema"}]} +// } +// { +// artifact_id:15, +// execution_id: 12, +// type:DECLARED_OUTPUT, +// path:{step:[{"key":"my_result"}]} +// } +// // Other event types include INPUT/OUTPUT and INTERNAL_INPUT/_OUTPUT. // * The INPUT/OUTPUT is an event that actually reads/writes an artifact by an -// execution. The input/output artifacts may not declared in the signature, -// For example, the trainer may output multiple caches of the parameters -// (as an OUTPUT), then finally write the SavedModel as a DECLARED_OUTPUT. +// +// execution. The input/output artifacts may not declared in the signature, +// For example, the trainer may output multiple caches of the parameters +// (as an OUTPUT), then finally write the SavedModel as a DECLARED_OUTPUT. +// // * The INTERNAL_INPUT/_OUTPUT are event types which are only meaningful to -// an orchestration system to keep track of the details for later debugging. -// For example, a fork happened conditioning on an artifact, then an execution -// is triggered, such fork implementating may need to log the read and write -// of artifacts and may not be worth displaying to the users. +// +// an orchestration system to keep track of the details for later debugging. +// For example, a fork happened conditioning on an artifact, then an execution +// is triggered, such fork implementating may need to log the read and write +// of artifacts and may not be worth displaying to the users. // // For instance, in the above example, // -// my_result = my_execution({"data":[3,7],"schema":8}) +// my_result = my_execution({"data":[3,7],"schema":8}) // // there is another execution (id: 15), which represents a `garbage_collection` // step in an orchestration system // -// gc_result = garbage_collection(my_result) +// gc_result = garbage_collection(my_result) // // that cleans `my_result` if needed. The details should be invisible to the // end users and lineage tracking. The orchestrator can emit following events: // -// { -// artifact_id: 15, -// execution_id: 15, -// type:INTERNAL_INPUT, -// } -// { -// artifact_id:16, // New artifact containing the GC job result. -// execution_id: 15, -// type:INTERNAL_OUTPUT, -// path:{step:[{"key":"gc_result"}]} -// } +// { +// artifact_id: 15, +// execution_id: 15, +// type:INTERNAL_INPUT, +// } +// { +// artifact_id:16, // New artifact containing the GC job result. +// execution_id: 15, +// type:INTERNAL_OUTPUT, +// path:{step:[{"key":"gc_result"}]} +// } type Event struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -2175,24 +2182,27 @@ func (x *UnionArtifactStructType) GetCandidates() []*ArtifactStructType { // // For example, suppose you have a method: // def infer_my_input_type(a): # try to infer the input type of this method. -// use_in_method_x(a) # with input type x_input -// use_in_method_y(a) # with input type y_input +// +// use_in_method_x(a) # with input type x_input +// use_in_method_y(a) # with input type y_input // // Given this information, you know that infer_my_input_type has // type {"intersection":{"constraints":[x_input, y_input]}}. // // IntersectionArtifactStructType intersection_type = {"constraints":[ -// {"dict":{"properties":{"schema":{"any":{}}}, -// "extra_properties":{"any":{}}}}, -// {"dict":{"properties":{"data":{"any":{}}}, -// "extra_properties":{"any":{}}}}]} +// +// {"dict":{"properties":{"schema":{"any":{}}}, +// "extra_properties":{"any":{}}}}, +// {"dict":{"properties":{"data":{"any":{}}}, +// "extra_properties":{"any":{}}}}]} +// // Since the first constraint requires the dictionary to have a schema // property, and the second constraint requires it to have a data property, this // is equivalent to: // ArtifactStructType other_type = -// {"dict":{"properties":{"schema":{"any":{}},"data":{"any":{}}}}, -// "extra_properties":{"any":{}}} // +// {"dict":{"properties":{"schema":{"any":{}},"data":{"any":{}}}}, +// "extra_properties":{"any":{}}} type IntersectionArtifactStructType struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -2298,19 +2308,21 @@ func (x *ListArtifactStructType) GetElement() *ArtifactStructType { // For example, StatsGen has an "optional" schema input. // A practical example of this is: // stats_gen_type = { -// "dict":{ -// "properties":{ -// "schema":{ -// "union_type":{ -// "none":{}, -// "simple":{...schema type...} -// }, -// }, -// "data":{ -// "simple":{...data_type...} -// } -// } -// } +// +// "dict":{ +// "properties":{ +// "schema":{ +// "union_type":{ +// "none":{}, +// "simple":{...schema type...} +// }, +// }, +// "data":{ +// "simple":{...data_type...} +// } +// } +// } +// // }; type NoneArtifactStructType struct { state protoimpl.MessageState