From 9755ab44fbd0e85dfee22722a60a4ec41a74b6a2 Mon Sep 17 00:00:00 2001 From: Future Outlier Date: Sat, 16 Dec 2023 22:50:35 +0800 Subject: [PATCH] remove secret Signed-off-by: Future Outlier --- .../gen/pb-cpp/flyteidl/admin/agent.pb.cc | 102 +------ flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h | 92 ------ flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go | 130 ++++---- .../pb-go/flyteidl/service/agent.swagger.json | 7 - .../flyteidl/admin/AgentOuterClass.java | 280 +----------------- flyteidl/gen/pb-js/flyteidl.d.ts | 6 - flyteidl/gen/pb-js/flyteidl.js | 25 -- .../gen/pb_python/flyteidl/admin/agent_pb2.py | 26 +- .../pb_python/flyteidl/admin/agent_pb2.pyi | 6 +- flyteidl/gen/pb_rust/flyteidl.admin.rs | 3 - flyteidl/protos/flyteidl/admin/agent.proto | 3 - 11 files changed, 102 insertions(+), 578 deletions(-) diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc index 2b88663f8e..b3e897e034 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc @@ -476,7 +476,6 @@ const ::google::protobuf::uint32 TableStruct_flyteidl_2fadmin_2fagent_2eproto::o PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, name_), PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, supported_task_types_), PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, is_sync_), - PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, secret_names_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::GetAgentRequest, _internal_metadata_), ~0u, // no _extensions_ @@ -515,10 +514,10 @@ static const ::google::protobuf::internal::MigrationSchema schemas[] PROTOBUF_SE { 85, -1, sizeof(::flyteidl::admin::DeleteTaskRequest)}, { 92, -1, sizeof(::flyteidl::admin::DeleteTaskResponse)}, { 97, -1, sizeof(::flyteidl::admin::Agent)}, - { 106, -1, sizeof(::flyteidl::admin::GetAgentRequest)}, - { 112, -1, sizeof(::flyteidl::admin::GetAgentResponse)}, - { 118, -1, sizeof(::flyteidl::admin::ListAgentsRequest)}, - { 123, -1, sizeof(::flyteidl::admin::ListAgentsResponse)}, + { 105, -1, sizeof(::flyteidl::admin::GetAgentRequest)}, + { 111, -1, sizeof(::flyteidl::admin::GetAgentResponse)}, + { 117, -1, sizeof(::flyteidl::admin::ListAgentsRequest)}, + { 122, -1, sizeof(::flyteidl::admin::ListAgentsResponse)}, }; static ::google::protobuf::Message const * const file_default_instances[] = { @@ -584,23 +583,22 @@ const char descriptor_table_protodef_flyteidl_2fadmin_2fagent_2eproto[] = "\007outputs\030\002 \001(\0132\031.flyteidl.core.LiteralMa" "p\022\017\n\007message\030\003 \001(\t\"=\n\021DeleteTaskRequest\022" "\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(" - "\014\"\024\n\022DeleteTaskResponse\"Z\n\005Agent\022\014\n\004name" + "\014\"\024\n\022DeleteTaskResponse\"D\n\005Agent\022\014\n\004name" "\030\001 \001(\t\022\034\n\024supported_task_types\030\002 \003(\t\022\017\n\007" - "is_sync\030\003 \001(\010\022\024\n\014secret_names\030\004 \003(\t\"\037\n\017G" - "etAgentRequest\022\014\n\004name\030\001 \001(\t\"8\n\020GetAgent" - "Response\022$\n\005agent\030\001 \001(\0132\025.flyteidl.admin" - ".Agent\"\023\n\021ListAgentsRequest\";\n\022ListAgent" - "sResponse\022%\n\006agents\030\001 \003(\0132\025.flyteidl.adm" - "in.Agent*^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000" - "\022\025\n\021PERMANENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007" - "RUNNING\020\003\022\r\n\tSUCCEEDED\020\004B=Z;github.com/f" - "lyteorg/flyte/flyteidl/gen/pb-go/flyteid" - "l/adminb\006proto3" + "is_sync\030\003 \001(\010\"\037\n\017GetAgentRequest\022\014\n\004name" + "\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005agent\030\001 \001(" + "\0132\025.flyteidl.admin.Agent\"\023\n\021ListAgentsRe" + "quest\";\n\022ListAgentsResponse\022%\n\006agents\030\001 " + "\003(\0132\025.flyteidl.admin.Agent*^\n\005State\022\025\n\021R" + "ETRYABLE_FAILURE\020\000\022\025\n\021PERMANENT_FAILURE\020" + "\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSUCCEEDED" + "\020\004B=Z;github.com/flyteorg/flyte/flyteidl" + "/gen/pb-go/flyteidl/adminb\006proto3" ; ::google::protobuf::internal::DescriptorTable descriptor_table_flyteidl_2fadmin_2fagent_2eproto = { false, InitDefaults_flyteidl_2fadmin_2fagent_2eproto, descriptor_table_protodef_flyteidl_2fadmin_2fagent_2eproto, - "flyteidl/admin/agent.proto", &assign_descriptors_table_flyteidl_2fadmin_2fagent_2eproto, 1895, + "flyteidl/admin/agent.proto", &assign_descriptors_table_flyteidl_2fadmin_2fagent_2eproto, 1873, }; void AddDescriptors_flyteidl_2fadmin_2fagent_2eproto() { @@ -4390,7 +4388,6 @@ class Agent::HasBitSetters { const int Agent::kNameFieldNumber; const int Agent::kSupportedTaskTypesFieldNumber; const int Agent::kIsSyncFieldNumber; -const int Agent::kSecretNamesFieldNumber; #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 Agent::Agent() @@ -4401,8 +4398,7 @@ Agent::Agent() Agent::Agent(const Agent& from) : ::google::protobuf::Message(), _internal_metadata_(nullptr), - supported_task_types_(from.supported_task_types_), - secret_names_(from.secret_names_) { + supported_task_types_(from.supported_task_types_) { _internal_metadata_.MergeFrom(from._internal_metadata_); name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); if (from.name().size() > 0) { @@ -4444,7 +4440,6 @@ void Agent::Clear() { (void) cached_has_bits; supported_task_types_.Clear(); - secret_names_.Clear(); name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); is_sync_ = false; _internal_metadata_.Clear(); @@ -4505,25 +4500,6 @@ const char* Agent::_InternalParse(const char* begin, const char* end, void* obje GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); break; } - // repeated string secret_names = 4; - case 4: { - if (static_cast<::google::protobuf::uint8>(tag) != 34) goto handle_unusual; - do { - ptr = ::google::protobuf::io::ReadSize(ptr, &size); - GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); - ctx->extra_parse_data().SetFieldName("flyteidl.admin.Agent.secret_names"); - object = msg->add_secret_names(); - if (size > end - ptr + ::google::protobuf::internal::ParseContext::kSlopBytes) { - parser_till_end = ::google::protobuf::internal::GreedyStringParserUTF8; - goto string_till_end; - } - GOOGLE_PROTOBUF_PARSER_ASSERT(::google::protobuf::internal::StringCheckUTF8(ptr, size, ctx)); - ::google::protobuf::internal::InlineGreedyStringParser(object, ptr, size, ctx); - ptr += size; - if (ptr >= end) break; - } while ((::google::protobuf::io::UnalignedLoad<::google::protobuf::uint64>(ptr) & 255) == 34 && (ptr += 1)); - break; - } default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { @@ -4602,22 +4578,6 @@ bool Agent::MergePartialFromCodedStream( break; } - // repeated string secret_names = 4; - case 4: { - if (static_cast< ::google::protobuf::uint8>(tag) == (34 & 0xFF)) { - DO_(::google::protobuf::internal::WireFormatLite::ReadString( - input, this->add_secret_names())); - DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( - this->secret_names(this->secret_names_size() - 1).data(), - static_cast(this->secret_names(this->secret_names_size() - 1).length()), - ::google::protobuf::internal::WireFormatLite::PARSE, - "flyteidl.admin.Agent.secret_names")); - } else { - goto handle_unusual; - } - break; - } - default: { handle_unusual: if (tag == 0) { @@ -4670,16 +4630,6 @@ void Agent::SerializeWithCachedSizes( ::google::protobuf::internal::WireFormatLite::WriteBool(3, this->is_sync(), output); } - // repeated string secret_names = 4; - for (int i = 0, n = this->secret_names_size(); i < n; i++) { - ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( - this->secret_names(i).data(), static_cast(this->secret_names(i).length()), - ::google::protobuf::internal::WireFormatLite::SERIALIZE, - "flyteidl.admin.Agent.secret_names"); - ::google::protobuf::internal::WireFormatLite::WriteString( - 4, this->secret_names(i), output); - } - if (_internal_metadata_.have_unknown_fields()) { ::google::protobuf::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); @@ -4719,16 +4669,6 @@ ::google::protobuf::uint8* Agent::InternalSerializeWithCachedSizesToArray( target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(3, this->is_sync(), target); } - // repeated string secret_names = 4; - for (int i = 0, n = this->secret_names_size(); i < n; i++) { - ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( - this->secret_names(i).data(), static_cast(this->secret_names(i).length()), - ::google::protobuf::internal::WireFormatLite::SERIALIZE, - "flyteidl.admin.Agent.secret_names"); - target = ::google::protobuf::internal::WireFormatLite:: - WriteStringToArray(4, this->secret_names(i), target); - } - if (_internal_metadata_.have_unknown_fields()) { target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); @@ -4758,14 +4698,6 @@ size_t Agent::ByteSizeLong() const { this->supported_task_types(i)); } - // repeated string secret_names = 4; - total_size += 1 * - ::google::protobuf::internal::FromIntSize(this->secret_names_size()); - for (int i = 0, n = this->secret_names_size(); i < n; i++) { - total_size += ::google::protobuf::internal::WireFormatLite::StringSize( - this->secret_names(i)); - } - // string name = 1; if (this->name().size() > 0) { total_size += 1 + @@ -4806,7 +4738,6 @@ void Agent::MergeFrom(const Agent& from) { (void) cached_has_bits; supported_task_types_.MergeFrom(from.supported_task_types_); - secret_names_.MergeFrom(from.secret_names_); if (from.name().size() > 0) { name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.name_); @@ -4842,7 +4773,6 @@ void Agent::InternalSwap(Agent* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); supported_task_types_.InternalSwap(CastToBase(&other->supported_task_types_)); - secret_names_.InternalSwap(CastToBase(&other->secret_names_)); name_.Swap(&other->name_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); swap(is_sync_, other->is_sync_); diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h index 0e78304e33..09aeb76cf0 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h @@ -1492,28 +1492,6 @@ class Agent final : const ::google::protobuf::RepeatedPtrField<::std::string>& supported_task_types() const; ::google::protobuf::RepeatedPtrField<::std::string>* mutable_supported_task_types(); - // repeated string secret_names = 4; - int secret_names_size() const; - void clear_secret_names(); - static const int kSecretNamesFieldNumber = 4; - const ::std::string& secret_names(int index) const; - ::std::string* mutable_secret_names(int index); - void set_secret_names(int index, const ::std::string& value); - #if LANG_CXX11 - void set_secret_names(int index, ::std::string&& value); - #endif - void set_secret_names(int index, const char* value); - void set_secret_names(int index, const char* value, size_t size); - ::std::string* add_secret_names(); - void add_secret_names(const ::std::string& value); - #if LANG_CXX11 - void add_secret_names(::std::string&& value); - #endif - void add_secret_names(const char* value); - void add_secret_names(const char* value, size_t size); - const ::google::protobuf::RepeatedPtrField<::std::string>& secret_names() const; - ::google::protobuf::RepeatedPtrField<::std::string>* mutable_secret_names(); - // string name = 1; void clear_name(); static const int kNameFieldNumber = 1; @@ -1540,7 +1518,6 @@ class Agent final : ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; ::google::protobuf::RepeatedPtrField<::std::string> supported_task_types_; - ::google::protobuf::RepeatedPtrField<::std::string> secret_names_; ::google::protobuf::internal::ArenaStringPtr name_; bool is_sync_; mutable ::google::protobuf::internal::CachedSize _cached_size_; @@ -3063,75 +3040,6 @@ inline void Agent::set_is_sync(bool value) { // @@protoc_insertion_point(field_set:flyteidl.admin.Agent.is_sync) } -// repeated string secret_names = 4; -inline int Agent::secret_names_size() const { - return secret_names_.size(); -} -inline void Agent::clear_secret_names() { - secret_names_.Clear(); -} -inline const ::std::string& Agent::secret_names(int index) const { - // @@protoc_insertion_point(field_get:flyteidl.admin.Agent.secret_names) - return secret_names_.Get(index); -} -inline ::std::string* Agent::mutable_secret_names(int index) { - // @@protoc_insertion_point(field_mutable:flyteidl.admin.Agent.secret_names) - return secret_names_.Mutable(index); -} -inline void Agent::set_secret_names(int index, const ::std::string& value) { - // @@protoc_insertion_point(field_set:flyteidl.admin.Agent.secret_names) - secret_names_.Mutable(index)->assign(value); -} -#if LANG_CXX11 -inline void Agent::set_secret_names(int index, ::std::string&& value) { - // @@protoc_insertion_point(field_set:flyteidl.admin.Agent.secret_names) - secret_names_.Mutable(index)->assign(std::move(value)); -} -#endif -inline void Agent::set_secret_names(int index, const char* value) { - GOOGLE_DCHECK(value != nullptr); - secret_names_.Mutable(index)->assign(value); - // @@protoc_insertion_point(field_set_char:flyteidl.admin.Agent.secret_names) -} -inline void Agent::set_secret_names(int index, const char* value, size_t size) { - secret_names_.Mutable(index)->assign( - reinterpret_cast(value), size); - // @@protoc_insertion_point(field_set_pointer:flyteidl.admin.Agent.secret_names) -} -inline ::std::string* Agent::add_secret_names() { - // @@protoc_insertion_point(field_add_mutable:flyteidl.admin.Agent.secret_names) - return secret_names_.Add(); -} -inline void Agent::add_secret_names(const ::std::string& value) { - secret_names_.Add()->assign(value); - // @@protoc_insertion_point(field_add:flyteidl.admin.Agent.secret_names) -} -#if LANG_CXX11 -inline void Agent::add_secret_names(::std::string&& value) { - secret_names_.Add(std::move(value)); - // @@protoc_insertion_point(field_add:flyteidl.admin.Agent.secret_names) -} -#endif -inline void Agent::add_secret_names(const char* value) { - GOOGLE_DCHECK(value != nullptr); - secret_names_.Add()->assign(value); - // @@protoc_insertion_point(field_add_char:flyteidl.admin.Agent.secret_names) -} -inline void Agent::add_secret_names(const char* value, size_t size) { - secret_names_.Add()->assign(reinterpret_cast(value), size); - // @@protoc_insertion_point(field_add_pointer:flyteidl.admin.Agent.secret_names) -} -inline const ::google::protobuf::RepeatedPtrField<::std::string>& -Agent::secret_names() const { - // @@protoc_insertion_point(field_list:flyteidl.admin.Agent.secret_names) - return secret_names_; -} -inline ::google::protobuf::RepeatedPtrField<::std::string>* -Agent::mutable_secret_names() { - // @@protoc_insertion_point(field_mutable_list:flyteidl.admin.Agent.secret_names) - return &secret_names_; -} - // ------------------------------------------------------------------- // GetAgentRequest diff --git a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go index 38ca368e94..af2e3ecf66 100644 --- a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go +++ b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go @@ -512,9 +512,7 @@ type Agent struct { // SupportedTaskTypes are the types of the tasks that the agent can handle. SupportedTaskTypes []string `protobuf:"bytes,2,rep,name=supported_task_types,json=supportedTaskTypes,proto3" json:"supported_task_types,omitempty"` // IsSync indicates whether this agent is a sync agent. Sync agents are expected to return their results synchronously when called by propeller. Given that sync agents can affect the performance of the system, it's important to enforce strict timeout policies. An Async agent, on the other hand, is required to be able to identify jobs by an identifier and query for job statuses as jobs progress. - IsSync bool `protobuf:"varint,3,opt,name=is_sync,json=isSync,proto3" json:"is_sync,omitempty"` - // SecretNames is a list of secrets the agent requires to execute tasks. - SecretNames []string `protobuf:"bytes,4,rep,name=secret_names,json=secretNames,proto3" json:"secret_names,omitempty"` + IsSync bool `protobuf:"varint,3,opt,name=is_sync,json=isSync,proto3" json:"is_sync,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -566,13 +564,6 @@ func (m *Agent) GetIsSync() bool { return false } -func (m *Agent) GetSecretNames() []string { - if m != nil { - return m.SecretNames - } - return nil -} - // A request to get an agent. type GetAgentRequest struct { // The name of the agent. @@ -750,64 +741,63 @@ func init() { func init() { proto.RegisterFile("flyteidl/admin/agent.proto", fileDescriptor_c434e52bb0028071) } var fileDescriptor_c434e52bb0028071 = []byte{ - // 940 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0x7f, 0x6f, 0xdb, 0x54, - 0x14, 0x25, 0x4d, 0x93, 0x26, 0x37, 0x59, 0x97, 0xbc, 0x35, 0xcc, 0xcd, 0x06, 0x2a, 0x46, 0x43, - 0x15, 0xd3, 0x1c, 0xd6, 0x22, 0xe8, 0x86, 0x60, 0xca, 0x5a, 0x53, 0x2a, 0xa5, 0x51, 0xf5, 0x92, - 0x22, 0x40, 0x02, 0xeb, 0xc5, 0xb9, 0x0d, 0x56, 0x1c, 0xdb, 0xf8, 0x3d, 0x57, 0x8b, 0xc4, 0xdf, - 0x48, 0xfb, 0x06, 0x7c, 0x5c, 0xe4, 0xf7, 0x9e, 0xdd, 0x24, 0xcb, 0x50, 0xab, 0xfd, 0x67, 0xdf, - 0x73, 0xee, 0xb9, 0xf7, 0xdd, 0x7b, 0xfc, 0x03, 0xda, 0x57, 0xfe, 0x5c, 0xa0, 0x37, 0xf6, 0x3b, - 0x6c, 0x3c, 0xf3, 0x82, 0x0e, 0x9b, 0x60, 0x20, 0xac, 0x28, 0x0e, 0x45, 0x48, 0xb6, 0x33, 0xcc, - 0x92, 0x58, 0xfb, 0x71, 0xce, 0x75, 0xc3, 0x18, 0x3b, 0xbe, 0x27, 0x30, 0x66, 0x3e, 0x57, 0xec, - 0xf6, 0xee, 0x32, 0x2a, 0x18, 0x9f, 0x66, 0xd0, 0x27, 0xcb, 0x90, 0x17, 0x08, 0x8c, 0xaf, 0x98, - 0x8b, 0x1a, 0xfe, 0x74, 0x05, 0x1e, 0x63, 0x20, 0xbc, 0x2b, 0x0f, 0xe3, 0xf5, 0xe9, 0xf8, 0x06, - 0xdd, 0x44, 0x78, 0x61, 0xa0, 0x60, 0xf3, 0xdf, 0x12, 0xb4, 0x86, 0x8c, 0x4f, 0xed, 0x2c, 0x7e, - 0x8e, 0x82, 0x8d, 0x99, 0x60, 0x84, 0x42, 0x33, 0x6d, 0xc3, 0xc9, 0x33, 0x1c, 0x6f, 0x6c, 0x14, - 0xf6, 0x0a, 0xfb, 0xb5, 0x83, 0x2f, 0xac, 0xfc, 0x70, 0xa9, 0xa8, 0xb5, 0x24, 0x70, 0x96, 0x77, - 0x40, 0xef, 0x8b, 0x65, 0x80, 0x3c, 0x86, 0x6a, 0xc0, 0x66, 0xc8, 0x23, 0xe6, 0xa2, 0xb1, 0xb1, - 0x57, 0xd8, 0xaf, 0xd2, 0x9b, 0x00, 0x39, 0x83, 0xb2, 0xcf, 0x46, 0xe8, 0x73, 0xa3, 0xb8, 0x57, - 0xdc, 0xaf, 0x1d, 0x3c, 0xb7, 0x96, 0x67, 0x68, 0xad, 0x6d, 0xd4, 0xea, 0xc9, 0x1c, 0x3b, 0x10, - 0xf1, 0x9c, 0x6a, 0x01, 0xf2, 0x0b, 0xd4, 0x58, 0x10, 0x84, 0x82, 0xa5, 0x4c, 0x6e, 0x6c, 0x4a, - 0xbd, 0x6f, 0x6e, 0xa7, 0xd7, 0xbd, 0x49, 0x54, 0xa2, 0x8b, 0x52, 0xc4, 0x82, 0x07, 0xd3, 0x23, - 0xee, 0x70, 0x8c, 0xaf, 0x3d, 0x17, 0x1d, 0xe6, 0xba, 0x61, 0x12, 0x08, 0xa3, 0x24, 0x0f, 0xd3, - 0x9c, 0x1e, 0xf1, 0x81, 0x42, 0xba, 0x0a, 0x20, 0x02, 0x5a, 0x18, 0x5c, 0x7b, 0x71, 0x18, 0xcc, - 0x30, 0x10, 0xce, 0x35, 0x8b, 0x3d, 0x36, 0xf2, 0x91, 0x1b, 0x65, 0xd9, 0xd3, 0xab, 0xdb, 0xf5, - 0x64, 0xdf, 0x48, 0xfc, 0x9c, 0x29, 0xa8, 0xe6, 0x76, 0x70, 0x0d, 0xd4, 0x7e, 0x01, 0xb5, 0x85, - 0xb1, 0x90, 0x06, 0x14, 0xa7, 0x38, 0x97, 0xdb, 0xab, 0xd2, 0xf4, 0x92, 0xec, 0x40, 0xe9, 0x9a, - 0xf9, 0x49, 0xb6, 0x05, 0x75, 0xf3, 0x72, 0xe3, 0xa8, 0xd0, 0xfe, 0x01, 0x1a, 0xab, 0x13, 0xb8, - 0x53, 0xfe, 0x29, 0xec, 0xbe, 0xb7, 0xdb, 0xbb, 0x08, 0x99, 0x6f, 0x8b, 0xd0, 0x3c, 0x8e, 0x91, - 0x09, 0x4c, 0x67, 0x42, 0xf1, 0xaf, 0x04, 0xb9, 0x20, 0xcf, 0xa1, 0xec, 0x05, 0x51, 0x22, 0xb8, - 0xf6, 0xe2, 0xee, 0x8a, 0x17, 0x7b, 0xea, 0xc1, 0x3a, 0x67, 0x11, 0xd5, 0x44, 0xf2, 0x2d, 0x54, - 0x04, 0xce, 0x22, 0x9f, 0x09, 0x55, 0xa5, 0x76, 0xf0, 0x68, 0x8d, 0x81, 0x87, 0x9a, 0x42, 0x73, - 0x32, 0xf9, 0x1c, 0xee, 0x85, 0x89, 0x88, 0x12, 0xe1, 0x44, 0x31, 0x5e, 0x79, 0x6f, 0x8c, 0xa2, - 0xec, 0xb1, 0xae, 0x82, 0x17, 0x32, 0x46, 0x7e, 0x87, 0x87, 0x2b, 0xcf, 0xc9, 0x4c, 0x6f, 0xcd, - 0xd8, 0x94, 0xc5, 0x9e, 0xdc, 0x6a, 0xc5, 0xb4, 0x25, 0xd6, 0x3e, 0x86, 0x3f, 0xc1, 0x16, 0x47, - 0x37, 0x46, 0xc1, 0x8d, 0x92, 0x74, 0x8c, 0xb5, 0x2a, 0xf7, 0xce, 0x8c, 0xac, 0x81, 0x4a, 0x50, - 0x06, 0xc9, 0xd2, 0xdb, 0x2f, 0xa1, 0xbe, 0x08, 0xdc, 0x69, 0x17, 0x2f, 0x80, 0x2c, 0x96, 0xe1, - 0x51, 0x18, 0x70, 0x39, 0x9f, 0x18, 0x79, 0x98, 0xc4, 0x2e, 0xca, 0x43, 0x4b, 0xad, 0x3a, 0xad, - 0x67, 0xc1, 0xf4, 0x10, 0x26, 0x85, 0xed, 0x53, 0x14, 0x8b, 0x2b, 0x7c, 0x04, 0x55, 0x39, 0x31, - 0x31, 0x8f, 0x50, 0x97, 0xaf, 0xa4, 0x81, 0xe1, 0x3c, 0x5a, 0xa3, 0xb9, 0xb1, 0x46, 0xf3, 0x6f, - 0xb8, 0x9f, 0x6b, 0xea, 0x5e, 0xbe, 0x86, 0x4a, 0x46, 0xd1, 0xce, 0x30, 0x56, 0x07, 0x45, 0x35, - 0x4e, 0x73, 0x26, 0x39, 0x84, 0xaa, 0x1f, 0x4e, 0x1c, 0xdf, 0x0b, 0xa6, 0xdc, 0xd8, 0x90, 0xf3, - 0xfd, 0x78, 0x8d, 0x37, 0x7a, 0xe1, 0x84, 0x56, 0xfc, 0x70, 0xd2, 0x4b, 0x79, 0xe6, 0x3f, 0x05, - 0xa8, 0x64, 0x5a, 0xe4, 0x29, 0x94, 0xb8, 0x48, 0x9d, 0x95, 0x16, 0xdd, 0x3e, 0x68, 0xad, 0x16, - 0x1d, 0xa4, 0x20, 0x55, 0x1c, 0x72, 0x08, 0x5b, 0xca, 0x3b, 0x5c, 0x1b, 0xf1, 0x7f, 0xdc, 0x9b, - 0x31, 0x89, 0x01, 0x5b, 0x33, 0xe4, 0x9c, 0x4d, 0x50, 0xfb, 0x2f, 0xbb, 0x35, 0x2f, 0xa1, 0x79, - 0x82, 0x3e, 0x2e, 0x3f, 0x20, 0x1f, 0x3e, 0xdd, 0x1d, 0x20, 0x8b, 0xb2, 0x6a, 0xc0, 0xe6, 0xdb, - 0x02, 0x94, 0xba, 0xe9, 0x07, 0x8e, 0x10, 0xd8, 0x4c, 0x5f, 0xda, 0x5a, 0x5c, 0x5e, 0x93, 0xaf, - 0x60, 0x87, 0x27, 0x51, 0x14, 0xc6, 0x02, 0xc7, 0x4e, 0x5e, 0x5f, 0xcd, 0xb4, 0x4a, 0x49, 0x8e, - 0x0d, 0x75, 0x27, 0x9c, 0x3c, 0x84, 0x2d, 0x8f, 0x3b, 0x7c, 0x1e, 0xb8, 0xf2, 0x58, 0x15, 0x5a, - 0xf6, 0xf8, 0x60, 0x1e, 0xb8, 0xe4, 0x33, 0xa8, 0x2b, 0xcb, 0x3a, 0xf2, 0xd3, 0x20, 0x5f, 0xde, - 0x55, 0x5a, 0x53, 0xb1, 0x7e, 0x1a, 0x32, 0x9f, 0xc8, 0xfd, 0xcb, 0x6e, 0xb2, 0x63, 0xaf, 0x69, - 0xca, 0x7c, 0x05, 0x8d, 0x1b, 0x9a, 0xf6, 0xc9, 0x53, 0x28, 0xc9, 0xcf, 0xb4, 0x36, 0xc9, 0x3b, - 0xfb, 0x52, 0x6c, 0xc5, 0x31, 0x1f, 0x40, 0xb3, 0xe7, 0x71, 0xa5, 0xc0, 0x75, 0x25, 0xf3, 0x18, - 0xc8, 0x62, 0x50, 0xeb, 0x3e, 0x83, 0xb2, 0xcc, 0x49, 0xdf, 0x4b, 0xc5, 0xf7, 0x0b, 0x6b, 0xd2, - 0x97, 0x7f, 0x40, 0x49, 0x3a, 0x83, 0xb4, 0xa0, 0x49, 0xed, 0x21, 0xfd, 0xb5, 0xfb, 0xba, 0x67, - 0x3b, 0x3f, 0x76, 0xcf, 0x7a, 0x97, 0xd4, 0x6e, 0x7c, 0x94, 0x86, 0x2f, 0x6c, 0x7a, 0xde, 0xed, - 0xdb, 0xfd, 0x61, 0x1e, 0x2e, 0x90, 0x1a, 0x6c, 0x5d, 0xd8, 0xfd, 0x93, 0xb3, 0xfe, 0x69, 0x63, - 0x23, 0xbd, 0xa1, 0x97, 0xfd, 0x7e, 0x7a, 0x53, 0x24, 0xf7, 0xa0, 0x3a, 0xb8, 0x3c, 0x3e, 0xb6, - 0xed, 0x13, 0xfb, 0xa4, 0xb1, 0xf9, 0xfa, 0xfb, 0xdf, 0xbe, 0x9b, 0x78, 0xe2, 0xcf, 0x64, 0x64, - 0xb9, 0xe1, 0xac, 0x23, 0x5b, 0x09, 0xe3, 0x89, 0xba, 0xe8, 0xe4, 0xbf, 0x04, 0x13, 0x0c, 0x3a, - 0xd1, 0xe8, 0xd9, 0x24, 0xec, 0x2c, 0xff, 0xc9, 0x8c, 0xca, 0xf2, 0xef, 0xe0, 0xf0, 0xbf, 0x00, - 0x00, 0x00, 0xff, 0xff, 0xf7, 0x75, 0x33, 0xb3, 0xe2, 0x08, 0x00, 0x00, + // 922 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xff, 0x6f, 0xe3, 0xc4, + 0x13, 0xfd, 0xa4, 0x69, 0xbe, 0x4d, 0x7a, 0xbd, 0x64, 0xaf, 0xf9, 0x9c, 0x9b, 0x3b, 0x50, 0x65, + 0x74, 0xa8, 0xe2, 0x74, 0x0e, 0xd7, 0x22, 0xe8, 0x1d, 0x82, 0x53, 0xae, 0x35, 0xa5, 0x52, 0x1a, + 0x55, 0x9b, 0x14, 0x01, 0x12, 0x58, 0x1b, 0x67, 0x12, 0xac, 0x38, 0xb6, 0xf1, 0xae, 0xab, 0x8b, + 0xc4, 0xcf, 0x48, 0xfc, 0x07, 0xfc, 0xb9, 0xc8, 0xbb, 0x6b, 0x37, 0xc9, 0xe5, 0x50, 0x2b, 0x7e, + 0xb3, 0xe7, 0xbd, 0x79, 0x33, 0x3b, 0xf3, 0x9c, 0x0d, 0xb4, 0x27, 0xfe, 0x42, 0xa0, 0x37, 0xf6, + 0x3b, 0x6c, 0x3c, 0xf7, 0x82, 0x0e, 0x9b, 0x62, 0x20, 0xac, 0x28, 0x0e, 0x45, 0x48, 0x76, 0x33, + 0xcc, 0x92, 0x58, 0xfb, 0x69, 0xce, 0x75, 0xc3, 0x18, 0x3b, 0xbe, 0x27, 0x30, 0x66, 0x3e, 0x57, + 0xec, 0xf6, 0xfe, 0x2a, 0x2a, 0x18, 0x9f, 0x65, 0xd0, 0x47, 0xab, 0x90, 0x17, 0x08, 0x8c, 0x27, + 0xcc, 0x45, 0x0d, 0x7f, 0xbc, 0x06, 0x8f, 0x31, 0x10, 0xde, 0xc4, 0xc3, 0x78, 0x73, 0x3a, 0xbe, + 0x43, 0x37, 0x11, 0x5e, 0x18, 0x28, 0xd8, 0xfc, 0xbb, 0x04, 0xad, 0x21, 0xe3, 0x33, 0x3b, 0x8b, + 0x5f, 0xa2, 0x60, 0x63, 0x26, 0x18, 0xa1, 0xd0, 0x4c, 0xdb, 0x70, 0xf2, 0x0c, 0xc7, 0x1b, 0x1b, + 0x85, 0x83, 0xc2, 0x61, 0xfd, 0xe8, 0x53, 0x2b, 0x3f, 0x5c, 0x2a, 0x6a, 0xad, 0x08, 0x5c, 0xe4, + 0x1d, 0xd0, 0x87, 0x62, 0x15, 0x20, 0x4f, 0xa1, 0x16, 0xb0, 0x39, 0xf2, 0x88, 0xb9, 0x68, 0x6c, + 0x1d, 0x14, 0x0e, 0x6b, 0xf4, 0x36, 0x40, 0x2e, 0xa0, 0xec, 0xb3, 0x11, 0xfa, 0xdc, 0x28, 0x1e, + 0x14, 0x0f, 0xeb, 0x47, 0x2f, 0xad, 0xd5, 0x19, 0x5a, 0x1b, 0x1b, 0xb5, 0x7a, 0x32, 0xc7, 0x0e, + 0x44, 0xbc, 0xa0, 0x5a, 0x80, 0xfc, 0x08, 0x75, 0x16, 0x04, 0xa1, 0x60, 0x29, 0x93, 0x1b, 0xdb, + 0x52, 0xef, 0xcb, 0xbb, 0xe9, 0x75, 0x6f, 0x13, 0x95, 0xe8, 0xb2, 0x14, 0xb1, 0xe0, 0xd1, 0xec, + 0x84, 0x3b, 0x1c, 0xe3, 0x1b, 0xcf, 0x45, 0x87, 0xb9, 0x6e, 0x98, 0x04, 0xc2, 0x28, 0xc9, 0xc3, + 0x34, 0x67, 0x27, 0x7c, 0xa0, 0x90, 0xae, 0x02, 0x88, 0x80, 0x16, 0x06, 0x37, 0x5e, 0x1c, 0x06, + 0x73, 0x0c, 0x84, 0x73, 0xc3, 0x62, 0x8f, 0x8d, 0x7c, 0xe4, 0x46, 0x59, 0xf6, 0xf4, 0xe6, 0x6e, + 0x3d, 0xd9, 0xb7, 0x12, 0x3f, 0x64, 0x0a, 0xaa, 0xb9, 0x3d, 0xdc, 0x00, 0xb5, 0x5f, 0x41, 0x7d, + 0x69, 0x2c, 0xa4, 0x01, 0xc5, 0x19, 0x2e, 0xe4, 0xf6, 0x6a, 0x34, 0x7d, 0x24, 0x7b, 0x50, 0xba, + 0x61, 0x7e, 0x92, 0x6d, 0x41, 0xbd, 0xbc, 0xde, 0x3a, 0x29, 0xb4, 0xbf, 0x85, 0xc6, 0xfa, 0x04, + 0xee, 0x95, 0x7f, 0x0e, 0xfb, 0x1f, 0xec, 0xf6, 0x3e, 0x42, 0xe6, 0x5f, 0x45, 0x68, 0x9e, 0xc6, + 0xc8, 0x04, 0xa6, 0x33, 0xa1, 0xf8, 0x7b, 0x82, 0x5c, 0x90, 0x97, 0x50, 0xf6, 0x82, 0x28, 0x11, + 0x5c, 0x7b, 0x71, 0x7f, 0xcd, 0x8b, 0x3d, 0xf5, 0x61, 0x5d, 0xb2, 0x88, 0x6a, 0x22, 0xf9, 0x0a, + 0xaa, 0x02, 0xe7, 0x91, 0xcf, 0x84, 0xaa, 0x52, 0x3f, 0x7a, 0xb2, 0xc1, 0xc0, 0x43, 0x4d, 0xa1, + 0x39, 0x99, 0x7c, 0x02, 0x0f, 0xc2, 0x44, 0x44, 0x89, 0x70, 0xa2, 0x18, 0x27, 0xde, 0x3b, 0xa3, + 0x28, 0x7b, 0xdc, 0x51, 0xc1, 0x2b, 0x19, 0x23, 0xbf, 0xc0, 0xe3, 0xb5, 0xef, 0x64, 0xae, 0xb7, + 0x66, 0x6c, 0xcb, 0x62, 0xcf, 0xee, 0xb4, 0x62, 0xda, 0x12, 0x1b, 0x3f, 0xc3, 0xef, 0xa1, 0xc2, + 0xd1, 0x8d, 0x51, 0x70, 0xa3, 0x24, 0x1d, 0x63, 0xad, 0xcb, 0xbd, 0x37, 0x23, 0x6b, 0xa0, 0x12, + 0x94, 0x41, 0xb2, 0xf4, 0xf6, 0x6b, 0xd8, 0x59, 0x06, 0xee, 0xb5, 0x8b, 0x57, 0x40, 0x96, 0xcb, + 0xf0, 0x28, 0x0c, 0xb8, 0x9c, 0x4f, 0x8c, 0x3c, 0x4c, 0x62, 0x17, 0xe5, 0xa1, 0xa5, 0xd6, 0x0e, + 0xdd, 0xc9, 0x82, 0xe9, 0x21, 0x4c, 0x0a, 0xbb, 0xe7, 0x28, 0x96, 0x57, 0xf8, 0x04, 0x6a, 0x72, + 0x62, 0x62, 0x11, 0xa1, 0x2e, 0x5f, 0x4d, 0x03, 0xc3, 0x45, 0xb4, 0x41, 0x73, 0x6b, 0x83, 0xe6, + 0x1f, 0xf0, 0x30, 0xd7, 0xd4, 0xbd, 0x7c, 0x01, 0xd5, 0x8c, 0xa2, 0x9d, 0x61, 0xac, 0x0f, 0x8a, + 0x6a, 0x9c, 0xe6, 0x4c, 0x72, 0x0c, 0x35, 0x3f, 0x9c, 0x3a, 0xbe, 0x17, 0xcc, 0xb8, 0xb1, 0x25, + 0xe7, 0xfb, 0xff, 0x0d, 0xde, 0xe8, 0x85, 0x53, 0x5a, 0xf5, 0xc3, 0x69, 0x2f, 0xe5, 0x99, 0x7f, + 0x16, 0xa0, 0x9a, 0x69, 0x91, 0xe7, 0x50, 0xe2, 0x22, 0x75, 0x56, 0x5a, 0x74, 0xf7, 0xa8, 0xb5, + 0x5e, 0x74, 0x90, 0x82, 0x54, 0x71, 0xc8, 0x31, 0x54, 0x94, 0x77, 0xb8, 0x36, 0xe2, 0xbf, 0xb8, + 0x37, 0x63, 0x12, 0x03, 0x2a, 0x73, 0xe4, 0x9c, 0x4d, 0x51, 0xfb, 0x2f, 0x7b, 0x35, 0xaf, 0xa1, + 0x79, 0x86, 0x3e, 0xae, 0x7e, 0x20, 0xff, 0x7d, 0xba, 0x7b, 0x40, 0x96, 0x65, 0xd5, 0x80, 0xcd, + 0x09, 0x94, 0xba, 0xe9, 0xfd, 0x46, 0x08, 0x6c, 0xa7, 0xbf, 0xd9, 0x5a, 0x5b, 0x3e, 0x93, 0xcf, + 0x61, 0x8f, 0x27, 0x51, 0x14, 0xc6, 0x02, 0xc7, 0x4e, 0x5e, 0x5e, 0x8d, 0xb4, 0x46, 0x49, 0x8e, + 0x0d, 0x75, 0x23, 0x9c, 0x3c, 0x86, 0x8a, 0xc7, 0x1d, 0xbe, 0x08, 0x5c, 0x79, 0xaa, 0x2a, 0x2d, + 0x7b, 0x7c, 0xb0, 0x08, 0x5c, 0xf3, 0x99, 0xdc, 0xad, 0x2c, 0x95, 0x1d, 0x69, 0x43, 0x45, 0xf3, + 0x0d, 0x34, 0x6e, 0x69, 0xda, 0x03, 0xcf, 0xa1, 0x24, 0xaf, 0x60, 0x6d, 0x80, 0xf7, 0x76, 0xa1, + 0xd8, 0x8a, 0x63, 0x3e, 0x82, 0x66, 0xcf, 0xe3, 0x4a, 0x81, 0xeb, 0x4a, 0xe6, 0x29, 0x90, 0xe5, + 0xa0, 0xd6, 0x7d, 0x01, 0x65, 0x99, 0x93, 0xfe, 0xe6, 0x14, 0x3f, 0x2c, 0xac, 0x49, 0x9f, 0xfd, + 0x0a, 0x25, 0xb9, 0x75, 0xd2, 0x82, 0x26, 0xb5, 0x87, 0xf4, 0xa7, 0xee, 0xdb, 0x9e, 0xed, 0x7c, + 0xd7, 0xbd, 0xe8, 0x5d, 0x53, 0xbb, 0xf1, 0xbf, 0x34, 0x7c, 0x65, 0xd3, 0xcb, 0x6e, 0xdf, 0xee, + 0x0f, 0xf3, 0x70, 0x81, 0xd4, 0xa1, 0x72, 0x65, 0xf7, 0xcf, 0x2e, 0xfa, 0xe7, 0x8d, 0xad, 0xf4, + 0x85, 0x5e, 0xf7, 0xfb, 0xe9, 0x4b, 0x91, 0x3c, 0x80, 0xda, 0xe0, 0xfa, 0xf4, 0xd4, 0xb6, 0xcf, + 0xec, 0xb3, 0xc6, 0xf6, 0xdb, 0x6f, 0x7e, 0xfe, 0x7a, 0xea, 0x89, 0xdf, 0x92, 0x91, 0xe5, 0x86, + 0xf3, 0x8e, 0x6c, 0x25, 0x8c, 0xa7, 0xea, 0xa1, 0x93, 0x5f, 0xf7, 0x53, 0x0c, 0x3a, 0xd1, 0xe8, + 0xc5, 0x34, 0xec, 0xac, 0xfe, 0x4b, 0x19, 0x95, 0xe5, 0xcd, 0x7f, 0xfc, 0x4f, 0x00, 0x00, 0x00, + 0xff, 0xff, 0x03, 0x67, 0xc5, 0xc9, 0xbe, 0x08, 0x00, 0x00, } diff --git a/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json b/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json index e79343c4b5..ea6db19960 100644 --- a/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json +++ b/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json @@ -234,13 +234,6 @@ "type": "boolean", "format": "boolean", "description": "IsSync indicates whether this agent is a sync agent. Sync agents are expected to return their results synchronously when called by propeller. Given that sync agents can affect the performance of the system, it's important to enforce strict timeout policies. An Async agent, on the other hand, is required to be able to identify jobs by an identifier and query for job statuses as jobs progress." - }, - "secret_names": { - "type": "array", - "items": { - "type": "string" - }, - "description": "SecretNames is a list of secrets the agent requires to execute tasks." } }, "description": "A message containing the agent metadata." diff --git a/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java b/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java index bd940affc5..d77b0d040a 100644 --- a/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java +++ b/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java @@ -8463,41 +8463,6 @@ public interface AgentOrBuilder extends * bool is_sync = 3; */ boolean getIsSync(); - - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - java.util.List - getSecretNamesList(); - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - int getSecretNamesCount(); - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - java.lang.String getSecretNames(int index); - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - com.google.protobuf.ByteString - getSecretNamesBytes(int index); } /** *
@@ -8518,7 +8483,6 @@ private Agent(com.google.protobuf.GeneratedMessageV3.Builder builder) {
     private Agent() {
       name_ = "";
       supportedTaskTypes_ = com.google.protobuf.LazyStringArrayList.EMPTY;
-      secretNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
     }
 
     @java.lang.Override
@@ -8565,15 +8529,6 @@ private Agent(
               isSync_ = input.readBool();
               break;
             }
-            case 34: {
-              java.lang.String s = input.readStringRequireUtf8();
-              if (!((mutable_bitField0_ & 0x00000008) != 0)) {
-                secretNames_ = new com.google.protobuf.LazyStringArrayList();
-                mutable_bitField0_ |= 0x00000008;
-              }
-              secretNames_.add(s);
-              break;
-            }
             default: {
               if (!parseUnknownField(
                   input, unknownFields, extensionRegistry, tag)) {
@@ -8592,9 +8547,6 @@ private Agent(
         if (((mutable_bitField0_ & 0x00000002) != 0)) {
           supportedTaskTypes_ = supportedTaskTypes_.getUnmodifiableView();
         }
-        if (((mutable_bitField0_ & 0x00000008) != 0)) {
-          secretNames_ = secretNames_.getUnmodifiableView();
-        }
         this.unknownFields = unknownFields.build();
         makeExtensionsImmutable();
       }
@@ -8713,51 +8665,6 @@ public boolean getIsSync() {
       return isSync_;
     }
 
-    public static final int SECRET_NAMES_FIELD_NUMBER = 4;
-    private com.google.protobuf.LazyStringList secretNames_;
-    /**
-     * 
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - public com.google.protobuf.ProtocolStringList - getSecretNamesList() { - return secretNames_; - } - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - public int getSecretNamesCount() { - return secretNames_.size(); - } - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - public java.lang.String getSecretNames(int index) { - return secretNames_.get(index); - } - /** - *
-     * SecretNames is a list of secrets the agent requires to execute tasks.
-     * 
- * - * repeated string secret_names = 4; - */ - public com.google.protobuf.ByteString - getSecretNamesBytes(int index) { - return secretNames_.getByteString(index); - } - private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -8781,9 +8688,6 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (isSync_ != false) { output.writeBool(3, isSync_); } - for (int i = 0; i < secretNames_.size(); i++) { - com.google.protobuf.GeneratedMessageV3.writeString(output, 4, secretNames_.getRaw(i)); - } unknownFields.writeTo(output); } @@ -8808,14 +8712,6 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeBoolSize(3, isSync_); } - { - int dataSize = 0; - for (int i = 0; i < secretNames_.size(); i++) { - dataSize += computeStringSizeNoTag(secretNames_.getRaw(i)); - } - size += dataSize; - size += 1 * getSecretNamesList().size(); - } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -8837,8 +8733,6 @@ public boolean equals(final java.lang.Object obj) { .equals(other.getSupportedTaskTypesList())) return false; if (getIsSync() != other.getIsSync()) return false; - if (!getSecretNamesList() - .equals(other.getSecretNamesList())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -8859,10 +8753,6 @@ public int hashCode() { hash = (37 * hash) + IS_SYNC_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( getIsSync()); - if (getSecretNamesCount() > 0) { - hash = (37 * hash) + SECRET_NAMES_FIELD_NUMBER; - hash = (53 * hash) + getSecretNamesList().hashCode(); - } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -9006,8 +8896,6 @@ public Builder clear() { bitField0_ = (bitField0_ & ~0x00000002); isSync_ = false; - secretNames_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000008); return this; } @@ -9043,11 +8931,6 @@ public flyteidl.admin.AgentOuterClass.Agent buildPartial() { } result.supportedTaskTypes_ = supportedTaskTypes_; result.isSync_ = isSync_; - if (((bitField0_ & 0x00000008) != 0)) { - secretNames_ = secretNames_.getUnmodifiableView(); - bitField0_ = (bitField0_ & ~0x00000008); - } - result.secretNames_ = secretNames_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -9114,16 +8997,6 @@ public Builder mergeFrom(flyteidl.admin.AgentOuterClass.Agent other) { if (other.getIsSync() != false) { setIsSync(other.getIsSync()); } - if (!other.secretNames_.isEmpty()) { - if (secretNames_.isEmpty()) { - secretNames_ = other.secretNames_; - bitField0_ = (bitField0_ & ~0x00000008); - } else { - ensureSecretNamesIsMutable(); - secretNames_.addAll(other.secretNames_); - } - onChanged(); - } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -9410,136 +9283,6 @@ public Builder clearIsSync() { onChanged(); return this; } - - private com.google.protobuf.LazyStringList secretNames_ = com.google.protobuf.LazyStringArrayList.EMPTY; - private void ensureSecretNamesIsMutable() { - if (!((bitField0_ & 0x00000008) != 0)) { - secretNames_ = new com.google.protobuf.LazyStringArrayList(secretNames_); - bitField0_ |= 0x00000008; - } - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public com.google.protobuf.ProtocolStringList - getSecretNamesList() { - return secretNames_.getUnmodifiableView(); - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public int getSecretNamesCount() { - return secretNames_.size(); - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public java.lang.String getSecretNames(int index) { - return secretNames_.get(index); - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public com.google.protobuf.ByteString - getSecretNamesBytes(int index) { - return secretNames_.getByteString(index); - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public Builder setSecretNames( - int index, java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureSecretNamesIsMutable(); - secretNames_.set(index, value); - onChanged(); - return this; - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public Builder addSecretNames( - java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureSecretNamesIsMutable(); - secretNames_.add(value); - onChanged(); - return this; - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public Builder addAllSecretNames( - java.lang.Iterable values) { - ensureSecretNamesIsMutable(); - com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, secretNames_); - onChanged(); - return this; - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public Builder clearSecretNames() { - secretNames_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000008); - onChanged(); - return this; - } - /** - *
-       * SecretNames is a list of secrets the agent requires to execute tasks.
-       * 
- * - * repeated string secret_names = 4; - */ - public Builder addSecretNamesBytes( - com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - checkByteStringIsUtf8(value); - ensureSecretNamesIsMutable(); - secretNames_.add(value); - onChanged(); - return this; - } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -12138,18 +11881,17 @@ public flyteidl.admin.AgentOuterClass.ListAgentsResponse getDefaultInstanceForTy "\007outputs\030\002 \001(\0132\031.flyteidl.core.LiteralMa" + "p\022\017\n\007message\030\003 \001(\t\"=\n\021DeleteTaskRequest\022" + "\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(" + - "\014\"\024\n\022DeleteTaskResponse\"Z\n\005Agent\022\014\n\004name" + + "\014\"\024\n\022DeleteTaskResponse\"D\n\005Agent\022\014\n\004name" + "\030\001 \001(\t\022\034\n\024supported_task_types\030\002 \003(\t\022\017\n\007" + - "is_sync\030\003 \001(\010\022\024\n\014secret_names\030\004 \003(\t\"\037\n\017G" + - "etAgentRequest\022\014\n\004name\030\001 \001(\t\"8\n\020GetAgent" + - "Response\022$\n\005agent\030\001 \001(\0132\025.flyteidl.admin" + - ".Agent\"\023\n\021ListAgentsRequest\";\n\022ListAgent" + - "sResponse\022%\n\006agents\030\001 \003(\0132\025.flyteidl.adm" + - "in.Agent*^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000" + - "\022\025\n\021PERMANENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007" + - "RUNNING\020\003\022\r\n\tSUCCEEDED\020\004B=Z;github.com/f" + - "lyteorg/flyte/flyteidl/gen/pb-go/flyteid" + - "l/adminb\006proto3" + "is_sync\030\003 \001(\010\"\037\n\017GetAgentRequest\022\014\n\004name" + + "\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005agent\030\001 \001(" + + "\0132\025.flyteidl.admin.Agent\"\023\n\021ListAgentsRe" + + "quest\";\n\022ListAgentsResponse\022%\n\006agents\030\001 " + + "\003(\0132\025.flyteidl.admin.Agent*^\n\005State\022\025\n\021R" + + "ETRYABLE_FAILURE\020\000\022\025\n\021PERMANENT_FAILURE\020" + + "\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSUCCEEDED" + + "\020\004B=Z;github.com/flyteorg/flyte/flyteidl" + + "/gen/pb-go/flyteidl/adminb\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { @@ -12245,7 +11987,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( internal_static_flyteidl_admin_Agent_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_Agent_descriptor, - new java.lang.String[] { "Name", "SupportedTaskTypes", "IsSync", "SecretNames", }); + new java.lang.String[] { "Name", "SupportedTaskTypes", "IsSync", }); internal_static_flyteidl_admin_GetAgentRequest_descriptor = getDescriptor().getMessageTypes().get(9); internal_static_flyteidl_admin_GetAgentRequest_fieldAccessorTable = new diff --git a/flyteidl/gen/pb-js/flyteidl.d.ts b/flyteidl/gen/pb-js/flyteidl.d.ts index 53b0150d92..e30784dad5 100644 --- a/flyteidl/gen/pb-js/flyteidl.d.ts +++ b/flyteidl/gen/pb-js/flyteidl.d.ts @@ -8370,9 +8370,6 @@ export namespace flyteidl { /** Agent isSync */ isSync?: (boolean|null); - - /** Agent secretNames */ - secretNames?: (string[]|null); } /** Represents an Agent. */ @@ -8393,9 +8390,6 @@ export namespace flyteidl { /** Agent isSync. */ public isSync: boolean; - /** Agent secretNames. */ - public secretNames: string[]; - /** * Creates a new Agent instance using the specified properties. * @param [properties] Properties to set diff --git a/flyteidl/gen/pb-js/flyteidl.js b/flyteidl/gen/pb-js/flyteidl.js index 586377bd30..c8c10034f4 100644 --- a/flyteidl/gen/pb-js/flyteidl.js +++ b/flyteidl/gen/pb-js/flyteidl.js @@ -20419,7 +20419,6 @@ * @property {string|null} [name] Agent name * @property {Array.|null} [supportedTaskTypes] Agent supportedTaskTypes * @property {boolean|null} [isSync] Agent isSync - * @property {Array.|null} [secretNames] Agent secretNames */ /** @@ -20432,7 +20431,6 @@ */ function Agent(properties) { this.supportedTaskTypes = []; - this.secretNames = []; if (properties) for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) if (properties[keys[i]] != null) @@ -20463,14 +20461,6 @@ */ Agent.prototype.isSync = false; - /** - * Agent secretNames. - * @member {Array.} secretNames - * @memberof flyteidl.admin.Agent - * @instance - */ - Agent.prototype.secretNames = $util.emptyArray; - /** * Creates a new Agent instance using the specified properties. * @function create @@ -20502,9 +20492,6 @@ writer.uint32(/* id 2, wireType 2 =*/18).string(message.supportedTaskTypes[i]); if (message.isSync != null && message.hasOwnProperty("isSync")) writer.uint32(/* id 3, wireType 0 =*/24).bool(message.isSync); - if (message.secretNames != null && message.secretNames.length) - for (var i = 0; i < message.secretNames.length; ++i) - writer.uint32(/* id 4, wireType 2 =*/34).string(message.secretNames[i]); return writer; }; @@ -20537,11 +20524,6 @@ case 3: message.isSync = reader.bool(); break; - case 4: - if (!(message.secretNames && message.secretNames.length)) - message.secretNames = []; - message.secretNames.push(reader.string()); - break; default: reader.skipType(tag & 7); break; @@ -20574,13 +20556,6 @@ if (message.isSync != null && message.hasOwnProperty("isSync")) if (typeof message.isSync !== "boolean") return "isSync: boolean expected"; - if (message.secretNames != null && message.hasOwnProperty("secretNames")) { - if (!Array.isArray(message.secretNames)) - return "secretNames: array expected"; - for (var i = 0; i < message.secretNames.length; ++i) - if (!$util.isString(message.secretNames[i])) - return "secretNames: string[] expected"; - } return null; }; diff --git a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py index 55fa65fa8a..275e1da82e 100644 --- a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py +++ b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py @@ -18,7 +18,7 @@ from flyteidl.core import execution_pb2 as flyteidl_dot_core_dot_execution__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1a\x66lyteidl/admin/agent.proto\x12\x0e\x66lyteidl.admin\x1a\x1c\x66lyteidl/core/literals.proto\x1a\x19\x66lyteidl/core/tasks.proto\x1a\x1d\x66lyteidl/core/interface.proto\x1a\x1e\x66lyteidl/core/identifier.proto\x1a\x1d\x66lyteidl/core/execution.proto\"\x98\x05\n\x15TaskExecutionMetadata\x12R\n\x11task_execution_id\x18\x01 \x01(\x0b\x32&.flyteidl.core.TaskExecutionIdentifierR\x0ftaskExecutionId\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12I\n\x06labels\x18\x03 \x03(\x0b\x32\x31.flyteidl.admin.TaskExecutionMetadata.LabelsEntryR\x06labels\x12X\n\x0b\x61nnotations\x18\x04 \x03(\x0b\x32\x36.flyteidl.admin.TaskExecutionMetadata.AnnotationsEntryR\x0b\x61nnotations\x12.\n\x13k8s_service_account\x18\x05 \x01(\tR\x11k8sServiceAccount\x12t\n\x15\x65nvironment_variables\x18\x06 \x03(\x0b\x32?.flyteidl.admin.TaskExecutionMetadata.EnvironmentVariablesEntryR\x14\x65nvironmentVariables\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aG\n\x19\x45nvironmentVariablesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"\x89\x03\n\x11\x43reateTaskRequest\x12\x31\n\x06inputs\x18\x01 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x06inputs\x12\x37\n\x08template\x18\x02 \x01(\x0b\x32\x1b.flyteidl.core.TaskTemplateR\x08template\x12#\n\routput_prefix\x18\x03 \x01(\tR\x0coutputPrefix\x12]\n\x17task_execution_metadata\x18\x04 \x01(\x0b\x32%.flyteidl.admin.TaskExecutionMetadataR\x15taskExecutionMetadata\x12H\n\x07secrets\x18\x05 \x03(\x0b\x32..flyteidl.admin.CreateTaskRequest.SecretsEntryR\x07secrets\x1a:\n\x0cSecretsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"9\n\x12\x43reateTaskResponse\x12#\n\rresource_meta\x18\x01 \x01(\x0cR\x0cresourceMeta\"R\n\x0eGetTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"|\n\x0fGetTaskResponse\x12\x34\n\x08resource\x18\x01 \x01(\x0b\x32\x18.flyteidl.admin.ResourceR\x08resource\x12\x33\n\tlog_links\x18\x02 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\"\x86\x01\n\x08Resource\x12+\n\x05state\x18\x01 \x01(\x0e\x32\x15.flyteidl.admin.StateR\x05state\x12\x33\n\x07outputs\x18\x02 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x07outputs\x12\x18\n\x07message\x18\x03 \x01(\tR\x07message\"U\n\x11\x44\x65leteTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"\x14\n\x12\x44\x65leteTaskResponse\"\x89\x01\n\x05\x41gent\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x30\n\x14supported_task_types\x18\x02 \x03(\tR\x12supportedTaskTypes\x12\x17\n\x07is_sync\x18\x03 \x01(\x08R\x06isSync\x12!\n\x0csecret_names\x18\x04 \x03(\tR\x0bsecretNames\"%\n\x0fGetAgentRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\"?\n\x10GetAgentResponse\x12+\n\x05\x61gent\x18\x01 \x01(\x0b\x32\x15.flyteidl.admin.AgentR\x05\x61gent\"\x13\n\x11ListAgentsRequest\"C\n\x12ListAgentsResponse\x12-\n\x06\x61gents\x18\x01 \x03(\x0b\x32\x15.flyteidl.admin.AgentR\x06\x61gents*^\n\x05State\x12\x15\n\x11RETRYABLE_FAILURE\x10\x00\x12\x15\n\x11PERMANENT_FAILURE\x10\x01\x12\x0b\n\x07PENDING\x10\x02\x12\x0b\n\x07RUNNING\x10\x03\x12\r\n\tSUCCEEDED\x10\x04\x42\xb6\x01\n\x12\x63om.flyteidl.adminB\nAgentProtoP\x01Z;github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin\xa2\x02\x03\x46\x41X\xaa\x02\x0e\x46lyteidl.Admin\xca\x02\x0e\x46lyteidl\\Admin\xe2\x02\x1a\x46lyteidl\\Admin\\GPBMetadata\xea\x02\x0f\x46lyteidl::Adminb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1a\x66lyteidl/admin/agent.proto\x12\x0e\x66lyteidl.admin\x1a\x1c\x66lyteidl/core/literals.proto\x1a\x19\x66lyteidl/core/tasks.proto\x1a\x1d\x66lyteidl/core/interface.proto\x1a\x1e\x66lyteidl/core/identifier.proto\x1a\x1d\x66lyteidl/core/execution.proto\"\x98\x05\n\x15TaskExecutionMetadata\x12R\n\x11task_execution_id\x18\x01 \x01(\x0b\x32&.flyteidl.core.TaskExecutionIdentifierR\x0ftaskExecutionId\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12I\n\x06labels\x18\x03 \x03(\x0b\x32\x31.flyteidl.admin.TaskExecutionMetadata.LabelsEntryR\x06labels\x12X\n\x0b\x61nnotations\x18\x04 \x03(\x0b\x32\x36.flyteidl.admin.TaskExecutionMetadata.AnnotationsEntryR\x0b\x61nnotations\x12.\n\x13k8s_service_account\x18\x05 \x01(\tR\x11k8sServiceAccount\x12t\n\x15\x65nvironment_variables\x18\x06 \x03(\x0b\x32?.flyteidl.admin.TaskExecutionMetadata.EnvironmentVariablesEntryR\x14\x65nvironmentVariables\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aG\n\x19\x45nvironmentVariablesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"\x89\x03\n\x11\x43reateTaskRequest\x12\x31\n\x06inputs\x18\x01 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x06inputs\x12\x37\n\x08template\x18\x02 \x01(\x0b\x32\x1b.flyteidl.core.TaskTemplateR\x08template\x12#\n\routput_prefix\x18\x03 \x01(\tR\x0coutputPrefix\x12]\n\x17task_execution_metadata\x18\x04 \x01(\x0b\x32%.flyteidl.admin.TaskExecutionMetadataR\x15taskExecutionMetadata\x12H\n\x07secrets\x18\x05 \x03(\x0b\x32..flyteidl.admin.CreateTaskRequest.SecretsEntryR\x07secrets\x1a:\n\x0cSecretsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"9\n\x12\x43reateTaskResponse\x12#\n\rresource_meta\x18\x01 \x01(\x0cR\x0cresourceMeta\"R\n\x0eGetTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"|\n\x0fGetTaskResponse\x12\x34\n\x08resource\x18\x01 \x01(\x0b\x32\x18.flyteidl.admin.ResourceR\x08resource\x12\x33\n\tlog_links\x18\x02 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\"\x86\x01\n\x08Resource\x12+\n\x05state\x18\x01 \x01(\x0e\x32\x15.flyteidl.admin.StateR\x05state\x12\x33\n\x07outputs\x18\x02 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x07outputs\x12\x18\n\x07message\x18\x03 \x01(\tR\x07message\"U\n\x11\x44\x65leteTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"\x14\n\x12\x44\x65leteTaskResponse\"f\n\x05\x41gent\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x30\n\x14supported_task_types\x18\x02 \x03(\tR\x12supportedTaskTypes\x12\x17\n\x07is_sync\x18\x03 \x01(\x08R\x06isSync\"%\n\x0fGetAgentRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\"?\n\x10GetAgentResponse\x12+\n\x05\x61gent\x18\x01 \x01(\x0b\x32\x15.flyteidl.admin.AgentR\x05\x61gent\"\x13\n\x11ListAgentsRequest\"C\n\x12ListAgentsResponse\x12-\n\x06\x61gents\x18\x01 \x03(\x0b\x32\x15.flyteidl.admin.AgentR\x06\x61gents*^\n\x05State\x12\x15\n\x11RETRYABLE_FAILURE\x10\x00\x12\x15\n\x11PERMANENT_FAILURE\x10\x01\x12\x0b\n\x07PENDING\x10\x02\x12\x0b\n\x07RUNNING\x10\x03\x12\r\n\tSUCCEEDED\x10\x04\x42\xb6\x01\n\x12\x63om.flyteidl.adminB\nAgentProtoP\x01Z;github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin\xa2\x02\x03\x46\x41X\xaa\x02\x0e\x46lyteidl.Admin\xca\x02\x0e\x46lyteidl\\Admin\xe2\x02\x1a\x46lyteidl\\Admin\\GPBMetadata\xea\x02\x0f\x46lyteidl::Adminb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -35,8 +35,8 @@ _TASKEXECUTIONMETADATA_ENVIRONMENTVARIABLESENTRY._serialized_options = b'8\001' _CREATETASKREQUEST_SECRETSENTRY._options = None _CREATETASKREQUEST_SECRETSENTRY._serialized_options = b'8\001' - _globals['_STATE']._serialized_start=2109 - _globals['_STATE']._serialized_end=2203 + _globals['_STATE']._serialized_start=2073 + _globals['_STATE']._serialized_end=2167 _globals['_TASKEXECUTIONMETADATA']._serialized_start=198 _globals['_TASKEXECUTIONMETADATA']._serialized_end=862 _globals['_TASKEXECUTIONMETADATA_LABELSENTRY']._serialized_start=668 @@ -61,14 +61,14 @@ _globals['_DELETETASKREQUEST']._serialized_end=1751 _globals['_DELETETASKRESPONSE']._serialized_start=1753 _globals['_DELETETASKRESPONSE']._serialized_end=1773 - _globals['_AGENT']._serialized_start=1776 - _globals['_AGENT']._serialized_end=1913 - _globals['_GETAGENTREQUEST']._serialized_start=1915 - _globals['_GETAGENTREQUEST']._serialized_end=1952 - _globals['_GETAGENTRESPONSE']._serialized_start=1954 - _globals['_GETAGENTRESPONSE']._serialized_end=2017 - _globals['_LISTAGENTSREQUEST']._serialized_start=2019 - _globals['_LISTAGENTSREQUEST']._serialized_end=2038 - _globals['_LISTAGENTSRESPONSE']._serialized_start=2040 - _globals['_LISTAGENTSRESPONSE']._serialized_end=2107 + _globals['_AGENT']._serialized_start=1775 + _globals['_AGENT']._serialized_end=1877 + _globals['_GETAGENTREQUEST']._serialized_start=1879 + _globals['_GETAGENTREQUEST']._serialized_end=1916 + _globals['_GETAGENTRESPONSE']._serialized_start=1918 + _globals['_GETAGENTRESPONSE']._serialized_end=1981 + _globals['_LISTAGENTSREQUEST']._serialized_start=1983 + _globals['_LISTAGENTSREQUEST']._serialized_end=2002 + _globals['_LISTAGENTSRESPONSE']._serialized_start=2004 + _globals['_LISTAGENTSRESPONSE']._serialized_end=2071 # @@protoc_insertion_point(module_scope) diff --git a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi index 81bca48431..30562d12e1 100644 --- a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi +++ b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi @@ -127,16 +127,14 @@ class DeleteTaskResponse(_message.Message): def __init__(self) -> None: ... class Agent(_message.Message): - __slots__ = ["name", "supported_task_types", "is_sync", "secret_names"] + __slots__ = ["name", "supported_task_types", "is_sync"] NAME_FIELD_NUMBER: _ClassVar[int] SUPPORTED_TASK_TYPES_FIELD_NUMBER: _ClassVar[int] IS_SYNC_FIELD_NUMBER: _ClassVar[int] - SECRET_NAMES_FIELD_NUMBER: _ClassVar[int] name: str supported_task_types: _containers.RepeatedScalarFieldContainer[str] is_sync: bool - secret_names: _containers.RepeatedScalarFieldContainer[str] - def __init__(self, name: _Optional[str] = ..., supported_task_types: _Optional[_Iterable[str]] = ..., is_sync: bool = ..., secret_names: _Optional[_Iterable[str]] = ...) -> None: ... + def __init__(self, name: _Optional[str] = ..., supported_task_types: _Optional[_Iterable[str]] = ..., is_sync: bool = ...) -> None: ... class GetAgentRequest(_message.Message): __slots__ = ["name"] diff --git a/flyteidl/gen/pb_rust/flyteidl.admin.rs b/flyteidl/gen/pb_rust/flyteidl.admin.rs index 31d9b3f2b3..1e31df455f 100644 --- a/flyteidl/gen/pb_rust/flyteidl.admin.rs +++ b/flyteidl/gen/pb_rust/flyteidl.admin.rs @@ -119,9 +119,6 @@ pub struct Agent { /// IsSync indicates whether this agent is a sync agent. Sync agents are expected to return their results synchronously when called by propeller. Given that sync agents can affect the performance of the system, it's important to enforce strict timeout policies. An Async agent, on the other hand, is required to be able to identify jobs by an identifier and query for job statuses as jobs progress. #[prost(bool, tag="3")] pub is_sync: bool, - /// SecretNames is a list of secrets the agent requires to execute tasks. - #[prost(string, repeated, tag="4")] - pub secret_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>, } /// A request to get an agent. #[allow(clippy::derive_partial_eq_without_eq)] diff --git a/flyteidl/protos/flyteidl/admin/agent.proto b/flyteidl/protos/flyteidl/admin/agent.proto index 668cb03009..7956f4bf62 100644 --- a/flyteidl/protos/flyteidl/admin/agent.proto +++ b/flyteidl/protos/flyteidl/admin/agent.proto @@ -106,9 +106,6 @@ message Agent { // IsSync indicates whether this agent is a sync agent. Sync agents are expected to return their results synchronously when called by propeller. Given that sync agents can affect the performance of the system, it's important to enforce strict timeout policies. An Async agent, on the other hand, is required to be able to identify jobs by an identifier and query for job statuses as jobs progress. bool is_sync = 3; - - // SecretNames is a list of secrets the agent requires to execute tasks. - repeated string secret_names = 4; } // A request to get an agent.