From 78eeefd118e1922b3ea9b1f7f097e0ac74461edb Mon Sep 17 00:00:00 2001 From: Future Outlier Date: Tue, 19 Dec 2023 11:08:58 +0800 Subject: [PATCH] remove is_sync proto Signed-off-by: Future Outlier --- .../gen/pb-cpp/flyteidl/admin/agent.pb.cc | 74 +++-------- flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h | 21 --- flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go | 124 ++++++++---------- .../pb-go/flyteidl/admin/agent.pb.validate.go | 2 - .../pb-go/flyteidl/service/agent.swagger.json | 5 - .../flyteidl/admin/AgentOuterClass.java | 105 ++------------- flyteidl/gen/pb-js/flyteidl.d.ts | 6 - flyteidl/gen/pb-js/flyteidl.js | 17 --- .../gen/pb_python/flyteidl/admin/agent_pb2.py | 24 ++-- .../pb_python/flyteidl/admin/agent_pb2.pyi | 6 +- flyteidl/gen/pb_rust/flyteidl.admin.rs | 3 - flyteidl/protos/flyteidl/admin/agent.proto | 3 - 12 files changed, 97 insertions(+), 293 deletions(-) diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc index b23cddfcf9..84cb28a2fc 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc @@ -445,7 +445,6 @@ const ::google::protobuf::uint32 TableStruct_flyteidl_2fadmin_2fagent_2eproto::o ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, name_), PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, supported_task_types_), - PROTOBUF_FIELD_OFFSET(::flyteidl::admin::Agent, is_sync_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::GetAgentRequest, _internal_metadata_), ~0u, // no _extensions_ @@ -483,10 +482,10 @@ static const ::google::protobuf::internal::MigrationSchema schemas[] PROTOBUF_SE { 75, -1, sizeof(::flyteidl::admin::DeleteTaskRequest)}, { 82, -1, sizeof(::flyteidl::admin::DeleteTaskResponse)}, { 87, -1, sizeof(::flyteidl::admin::Agent)}, - { 95, -1, sizeof(::flyteidl::admin::GetAgentRequest)}, - { 101, -1, sizeof(::flyteidl::admin::GetAgentResponse)}, - { 107, -1, sizeof(::flyteidl::admin::ListAgentsRequest)}, - { 112, -1, sizeof(::flyteidl::admin::ListAgentsResponse)}, + { 94, -1, sizeof(::flyteidl::admin::GetAgentRequest)}, + { 100, -1, sizeof(::flyteidl::admin::GetAgentResponse)}, + { 106, -1, sizeof(::flyteidl::admin::ListAgentsRequest)}, + { 111, -1, sizeof(::flyteidl::admin::ListAgentsResponse)}, }; static ::google::protobuf::Message const * const file_default_instances[] = { @@ -548,22 +547,22 @@ const char descriptor_table_protodef_flyteidl_2fadmin_2fagent_2eproto[] = "tate\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core.Li" "teralMap\022\017\n\007message\030\003 \001(\t\"=\n\021DeleteTaskR" "equest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_me" - "ta\030\002 \001(\014\"\024\n\022DeleteTaskResponse\"D\n\005Agent\022" + "ta\030\002 \001(\014\"\024\n\022DeleteTaskResponse\"3\n\005Agent\022" "\014\n\004name\030\001 \001(\t\022\034\n\024supported_task_types\030\002 " - "\003(\t\022\017\n\007is_sync\030\003 \001(\010\"\037\n\017GetAgentRequest\022" - "\014\n\004name\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005age" - "nt\030\001 \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListA" - "gentsRequest\";\n\022ListAgentsResponse\022%\n\006ag" - "ents\030\001 \003(\0132\025.flyteidl.admin.Agent*^\n\005Sta" - "te\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021PERMANENT_F" - "AILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSU" - "CCEEDED\020\004B=Z;github.com/flyteorg/flyte/f" - "lyteidl/gen/pb-go/flyteidl/adminb\006proto3" + "\003(\t\"\037\n\017GetAgentRequest\022\014\n\004name\030\001 \001(\t\"8\n\020" + "GetAgentResponse\022$\n\005agent\030\001 \001(\0132\025.flytei" + "dl.admin.Agent\"\023\n\021ListAgentsRequest\";\n\022L" + "istAgentsResponse\022%\n\006agents\030\001 \003(\0132\025.flyt" + "eidl.admin.Agent*^\n\005State\022\025\n\021RETRYABLE_F" + "AILURE\020\000\022\025\n\021PERMANENT_FAILURE\020\001\022\013\n\007PENDI" + "NG\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSUCCEEDED\020\004B=Z;gith" + "ub.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, 1760, + "flyteidl/admin/agent.proto", &assign_descriptors_table_flyteidl_2fadmin_2fagent_2eproto, 1743, }; void AddDescriptors_flyteidl_2fadmin_2fagent_2eproto() { @@ -4149,7 +4148,6 @@ class Agent::HasBitSetters { #if !defined(_MSC_VER) || _MSC_VER >= 1900 const int Agent::kNameFieldNumber; const int Agent::kSupportedTaskTypesFieldNumber; -const int Agent::kIsSyncFieldNumber; #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 Agent::Agent() @@ -4166,7 +4164,6 @@ Agent::Agent(const Agent& from) if (from.name().size() > 0) { name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.name_); } - is_sync_ = from.is_sync_; // @@protoc_insertion_point(copy_constructor:flyteidl.admin.Agent) } @@ -4174,7 +4171,6 @@ void Agent::SharedCtor() { ::google::protobuf::internal::InitSCC( &scc_info_Agent_flyteidl_2fadmin_2fagent_2eproto.base); name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); - is_sync_ = false; } Agent::~Agent() { @@ -4203,7 +4199,6 @@ void Agent::Clear() { supported_task_types_.Clear(); name_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); - is_sync_ = false; _internal_metadata_.Clear(); } @@ -4255,13 +4250,6 @@ const char* Agent::_InternalParse(const char* begin, const char* end, void* obje } while ((::google::protobuf::io::UnalignedLoad<::google::protobuf::uint64>(ptr) & 255) == 18 && (ptr += 1)); break; } - // bool is_sync = 3; - case 3: { - if (static_cast<::google::protobuf::uint8>(tag) != 24) goto handle_unusual; - msg->set_is_sync(::google::protobuf::internal::ReadVarint(&ptr)); - GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); - break; - } default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { @@ -4327,19 +4315,6 @@ bool Agent::MergePartialFromCodedStream( break; } - // bool is_sync = 3; - case 3: { - if (static_cast< ::google::protobuf::uint8>(tag) == (24 & 0xFF)) { - - DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< - bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( - input, &is_sync_))); - } else { - goto handle_unusual; - } - break; - } - default: { handle_unusual: if (tag == 0) { @@ -4387,11 +4362,6 @@ void Agent::SerializeWithCachedSizes( 2, this->supported_task_types(i), output); } - // bool is_sync = 3; - if (this->is_sync() != 0) { - ::google::protobuf::internal::WireFormatLite::WriteBool(3, this->is_sync(), output); - } - if (_internal_metadata_.have_unknown_fields()) { ::google::protobuf::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); @@ -4426,11 +4396,6 @@ ::google::protobuf::uint8* Agent::InternalSerializeWithCachedSizesToArray( WriteStringToArray(2, this->supported_task_types(i), target); } - // bool is_sync = 3; - if (this->is_sync() != 0) { - target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(3, this->is_sync(), target); - } - if (_internal_metadata_.have_unknown_fields()) { target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); @@ -4467,11 +4432,6 @@ size_t Agent::ByteSizeLong() const { this->name()); } - // bool is_sync = 3; - if (this->is_sync() != 0) { - total_size += 1 + 1; - } - int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; @@ -4504,9 +4464,6 @@ void Agent::MergeFrom(const Agent& from) { name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.name_); } - if (from.is_sync() != 0) { - set_is_sync(from.is_sync()); - } } void Agent::CopyFrom(const ::google::protobuf::Message& from) { @@ -4537,7 +4494,6 @@ void Agent::InternalSwap(Agent* other) { supported_task_types_.InternalSwap(CastToBase(&other->supported_task_types_)); name_.Swap(&other->name_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); - swap(is_sync_, other->is_sync_); } ::google::protobuf::Metadata Agent::GetMetadata() const { diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h index a00f79ae6f..7360e91d06 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h @@ -1462,12 +1462,6 @@ class Agent final : ::std::string* release_name(); void set_allocated_name(::std::string* name); - // bool is_sync = 3; - void clear_is_sync(); - static const int kIsSyncFieldNumber = 3; - bool is_sync() const; - void set_is_sync(bool value); - // @@protoc_insertion_point(class_scope:flyteidl.admin.Agent) private: class HasBitSetters; @@ -1475,7 +1469,6 @@ class Agent final : ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; ::google::protobuf::RepeatedPtrField<::std::string> supported_task_types_; ::google::protobuf::internal::ArenaStringPtr name_; - bool is_sync_; mutable ::google::protobuf::internal::CachedSize _cached_size_; friend struct ::TableStruct_flyteidl_2fadmin_2fagent_2eproto; }; @@ -2962,20 +2955,6 @@ Agent::mutable_supported_task_types() { return &supported_task_types_; } -// bool is_sync = 3; -inline void Agent::clear_is_sync() { - is_sync_ = false; -} -inline bool Agent::is_sync() const { - // @@protoc_insertion_point(field_get:flyteidl.admin.Agent.is_sync) - return is_sync_; -} -inline void Agent::set_is_sync(bool value) { - - is_sync_ = value; - // @@protoc_insertion_point(field_set:flyteidl.admin.Agent.is_sync) -} - // ------------------------------------------------------------------- // GetAgentRequest diff --git a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go index 5e17ad4994..aeb5a70ed1 100644 --- a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go +++ b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go @@ -499,9 +499,7 @@ type Agent struct { // Name is the developer-assigned name of the agent. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 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"` + SupportedTaskTypes []string `protobuf:"bytes,2,rep,name=supported_task_types,json=supportedTaskTypes,proto3" json:"supported_task_types,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -546,13 +544,6 @@ func (m *Agent) GetSupportedTaskTypes() []string { return nil } -func (m *Agent) GetIsSync() bool { - if m != nil { - return m.IsSync - } - return false -} - // A request to get an agent. type GetAgentRequest struct { // The name of the agent. @@ -729,61 +720,60 @@ func init() { func init() { proto.RegisterFile("flyteidl/admin/agent.proto", fileDescriptor_c434e52bb0028071) } var fileDescriptor_c434e52bb0028071 = []byte{ - // 887 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xf1, 0x6f, 0x22, 0x45, - 0x14, 0x16, 0x28, 0x14, 0x1e, 0xbd, 0x1e, 0xcc, 0x15, 0x6f, 0xcb, 0x9d, 0xa6, 0x59, 0x73, 0xa6, - 0xf1, 0x72, 0xe0, 0xb5, 0x46, 0x7b, 0x1a, 0xbd, 0x70, 0xed, 0xda, 0x34, 0xa1, 0xa4, 0x99, 0x52, - 0xa3, 0x26, 0xba, 0x19, 0x96, 0x07, 0x6e, 0x58, 0x66, 0xd7, 0x9d, 0xd9, 0xe6, 0x48, 0xfc, 0xcd, - 0xc4, 0xbf, 0xc1, 0x3f, 0xd7, 0xec, 0xcc, 0xec, 0x16, 0x90, 0x33, 0xbd, 0xf8, 0xdb, 0xce, 0xfb, - 0xbe, 0xf9, 0xde, 0x9b, 0xf7, 0xbd, 0x61, 0x80, 0xf6, 0x24, 0x58, 0x48, 0xf4, 0xc7, 0x41, 0x97, - 0x8d, 0xe7, 0x3e, 0xef, 0xb2, 0x29, 0x72, 0xd9, 0x89, 0xe2, 0x50, 0x86, 0x64, 0x37, 0xc3, 0x3a, - 0x0a, 0x6b, 0x3f, 0xcd, 0xb9, 0x5e, 0x18, 0x63, 0x37, 0xf0, 0x25, 0xc6, 0x2c, 0x10, 0x9a, 0xdd, - 0xde, 0x5f, 0x45, 0x25, 0x13, 0xb3, 0x0c, 0xfa, 0x68, 0x15, 0xf2, 0xb9, 0xc4, 0x78, 0xc2, 0x3c, - 0x34, 0xf0, 0xc7, 0x6b, 0xf0, 0x18, 0xb9, 0xf4, 0x27, 0x3e, 0xc6, 0x9b, 0xb7, 0xe3, 0x5b, 0xf4, - 0x12, 0xe9, 0x87, 0x5c, 0xc3, 0xf6, 0xdf, 0x65, 0x68, 0x0d, 0x99, 0x98, 0x39, 0x59, 0xfc, 0x12, - 0x25, 0x1b, 0x33, 0xc9, 0x08, 0x85, 0x66, 0x5a, 0x86, 0x9b, 0xef, 0x70, 0xfd, 0xb1, 0x55, 0x38, - 0x28, 0x1c, 0xd6, 0x8f, 0x3e, 0xed, 0xe4, 0x87, 0x4b, 0x45, 0x3b, 0x2b, 0x02, 0x17, 0x79, 0x05, - 0xf4, 0xa1, 0x5c, 0x05, 0xc8, 0x53, 0xa8, 0x71, 0x36, 0x47, 0x11, 0x31, 0x0f, 0xad, 0xe2, 0x41, - 0xe1, 0xb0, 0x46, 0xef, 0x02, 0xe4, 0x02, 0x2a, 0x01, 0x1b, 0x61, 0x20, 0xac, 0xd2, 0x41, 0xe9, - 0xb0, 0x7e, 0xf4, 0xb2, 0xb3, 0xda, 0xc3, 0xce, 0xc6, 0x42, 0x3b, 0x7d, 0xb5, 0xc7, 0xe1, 0x32, - 0x5e, 0x50, 0x23, 0x40, 0x7e, 0x84, 0x3a, 0xe3, 0x3c, 0x94, 0x2c, 0x65, 0x0a, 0x6b, 0x4b, 0xe9, - 0x7d, 0x79, 0x3f, 0xbd, 0xde, 0xdd, 0x46, 0x2d, 0xba, 0x2c, 0x45, 0x3a, 0xf0, 0x68, 0x76, 0x22, - 0x5c, 0x81, 0xf1, 0xad, 0xef, 0xa1, 0xcb, 0x3c, 0x2f, 0x4c, 0xb8, 0xb4, 0xca, 0xea, 0x30, 0xcd, - 0xd9, 0x89, 0xb8, 0xd6, 0x48, 0x4f, 0x03, 0x44, 0x42, 0x0b, 0xf9, 0xad, 0x1f, 0x87, 0x7c, 0x8e, - 0x5c, 0xba, 0xb7, 0x2c, 0xf6, 0xd9, 0x28, 0x40, 0x61, 0x55, 0x54, 0x4d, 0xaf, 0xef, 0x57, 0x93, - 0x73, 0x27, 0xf1, 0x43, 0xa6, 0xa0, 0x8b, 0xdb, 0xc3, 0x0d, 0x50, 0xfb, 0x15, 0xd4, 0x97, 0xda, - 0x42, 0x1a, 0x50, 0x9a, 0xe1, 0x42, 0xb9, 0x57, 0xa3, 0xe9, 0x27, 0xd9, 0x83, 0xf2, 0x2d, 0x0b, - 0x92, 0xcc, 0x05, 0xbd, 0xf8, 0xba, 0x78, 0x52, 0x68, 0x7f, 0x07, 0x8d, 0xf5, 0x0e, 0xbc, 0xd7, - 0xfe, 0x73, 0xd8, 0x7f, 0x67, 0xb5, 0xef, 0x23, 0x64, 0xff, 0x59, 0x84, 0xe6, 0x69, 0x8c, 0x4c, - 0x62, 0xda, 0x13, 0x8a, 0xbf, 0x27, 0x28, 0x24, 0x79, 0x09, 0x15, 0x9f, 0x47, 0x89, 0x14, 0x66, - 0x16, 0xf7, 0xd7, 0x66, 0xb1, 0xaf, 0x2f, 0xd6, 0x25, 0x8b, 0xa8, 0x21, 0x92, 0xaf, 0xa0, 0x2a, - 0x71, 0x1e, 0x05, 0x4c, 0xea, 0x2c, 0xf5, 0xa3, 0x27, 0x1b, 0x06, 0x78, 0x68, 0x28, 0x34, 0x27, - 0x93, 0x4f, 0xe0, 0x41, 0x98, 0xc8, 0x28, 0x91, 0x6e, 0x14, 0xe3, 0xc4, 0x7f, 0x6b, 0x95, 0x54, - 0x8d, 0x3b, 0x3a, 0x78, 0xa5, 0x62, 0xe4, 0x17, 0x78, 0xbc, 0x76, 0x4f, 0xe6, 0xc6, 0x35, 0x6b, - 0x4b, 0x25, 0x7b, 0x76, 0x2f, 0x8b, 0x69, 0x4b, 0x6e, 0x0a, 0xdb, 0xaf, 0x80, 0x2c, 0x37, 0x41, - 0x44, 0x21, 0x17, 0xaa, 0xb2, 0x18, 0x45, 0x98, 0xc4, 0x1e, 0xaa, 0x74, 0xaa, 0x19, 0x3b, 0x74, - 0x27, 0x0b, 0xa6, 0xdb, 0x6d, 0x0a, 0xbb, 0xe7, 0x28, 0x97, 0x9b, 0xf7, 0x04, 0x6a, 0xaa, 0x56, - 0xb9, 0x88, 0xd0, 0x98, 0x50, 0x4d, 0x03, 0xc3, 0x45, 0xb4, 0x41, 0xb3, 0xb8, 0x41, 0xf3, 0x0f, - 0x78, 0x98, 0x6b, 0x9a, 0x5a, 0xbe, 0x80, 0x6a, 0x46, 0x31, 0x9e, 0x58, 0xeb, 0x27, 0xa6, 0x06, - 0xa7, 0x39, 0x93, 0x1c, 0x43, 0x2d, 0x08, 0xa7, 0x6e, 0xe0, 0xf3, 0x99, 0xb0, 0x8a, 0xea, 0x2e, - 0x7c, 0xb8, 0xc1, 0x95, 0x7e, 0x38, 0xa5, 0xd5, 0x20, 0x9c, 0xf6, 0x53, 0x9e, 0xfd, 0x57, 0x01, - 0xaa, 0x99, 0x16, 0x79, 0x0e, 0x65, 0x21, 0x53, 0x4f, 0xd3, 0xa4, 0xbb, 0x47, 0xad, 0xf5, 0xa4, - 0xd7, 0x29, 0x48, 0x35, 0x87, 0x1c, 0xc3, 0xb6, 0x76, 0x4d, 0x98, 0x11, 0xf8, 0x8f, 0xb9, 0xc9, - 0x98, 0xc4, 0x82, 0xed, 0x39, 0x0a, 0xc1, 0xa6, 0x68, 0x9c, 0xcf, 0x96, 0xf6, 0x0d, 0x34, 0xcf, - 0x30, 0xc0, 0xd5, 0xd1, 0xfc, 0xff, 0xdd, 0xdd, 0x03, 0xb2, 0x2c, 0xab, 0x1b, 0x6c, 0x4f, 0xa0, - 0xdc, 0x4b, 0x5f, 0x16, 0x42, 0x60, 0x2b, 0xfd, 0xb5, 0x34, 0xda, 0xea, 0x9b, 0x7c, 0x0e, 0x7b, - 0x22, 0x89, 0xa2, 0x30, 0x96, 0x38, 0x76, 0xf3, 0xf4, 0xba, 0xa5, 0x35, 0x4a, 0x72, 0x6c, 0x68, - 0x0a, 0x11, 0xe4, 0x31, 0x6c, 0xfb, 0xc2, 0x15, 0x0b, 0xee, 0xa9, 0x53, 0x55, 0x69, 0xc5, 0x17, - 0xd7, 0x0b, 0xee, 0xd9, 0xcf, 0x94, 0xb7, 0x2a, 0x55, 0x76, 0xa4, 0x0d, 0x19, 0xed, 0xd7, 0xd0, - 0xb8, 0xa3, 0x99, 0x19, 0x78, 0x0e, 0x65, 0xf5, 0xf8, 0x99, 0x01, 0xf8, 0x97, 0x17, 0x9a, 0xad, - 0x39, 0xf6, 0x23, 0x68, 0xf6, 0x7d, 0xa1, 0x15, 0x84, 0xc9, 0x64, 0x9f, 0x02, 0x59, 0x0e, 0x1a, - 0xdd, 0x17, 0x50, 0x51, 0x7b, 0xd2, 0xdb, 0x5e, 0x7a, 0xb7, 0xb0, 0x21, 0x7d, 0xf6, 0x2b, 0x94, - 0x95, 0xeb, 0xa4, 0x05, 0x4d, 0xea, 0x0c, 0xe9, 0x4f, 0xbd, 0x37, 0x7d, 0xc7, 0xfd, 0xbe, 0x77, - 0xd1, 0xbf, 0xa1, 0x4e, 0xe3, 0x83, 0x34, 0x7c, 0xe5, 0xd0, 0xcb, 0xde, 0xc0, 0x19, 0x0c, 0xf3, - 0x70, 0x81, 0xd4, 0x61, 0xfb, 0xca, 0x19, 0x9c, 0x5d, 0x0c, 0xce, 0x1b, 0xc5, 0x74, 0x41, 0x6f, - 0x06, 0x83, 0x74, 0x51, 0x22, 0x0f, 0xa0, 0x76, 0x7d, 0x73, 0x7a, 0xea, 0x38, 0x67, 0xce, 0x59, - 0x63, 0xeb, 0xcd, 0xb7, 0x3f, 0x7f, 0x33, 0xf5, 0xe5, 0x6f, 0xc9, 0xa8, 0xe3, 0x85, 0xf3, 0xae, - 0x2a, 0x25, 0x8c, 0xa7, 0xfa, 0xa3, 0x9b, 0x3f, 0xb4, 0x53, 0xe4, 0xdd, 0x68, 0xf4, 0x62, 0x1a, - 0x76, 0x57, 0xff, 0x1f, 0x8c, 0x2a, 0xea, 0xcd, 0x3d, 0xfe, 0x27, 0x00, 0x00, 0xff, 0xff, 0xfb, - 0xe3, 0xf7, 0x83, 0x38, 0x08, 0x00, 0x00, + // 869 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xf1, 0x6f, 0xdb, 0x44, + 0x14, 0x26, 0x49, 0xd3, 0x26, 0x2f, 0x5d, 0x97, 0xdc, 0x1a, 0x70, 0xb3, 0x81, 0x2a, 0xa3, 0xa1, + 0x8a, 0x69, 0x0e, 0x6b, 0x11, 0x74, 0x20, 0x98, 0xb2, 0xd6, 0x54, 0x95, 0xd2, 0xa8, 0xba, 0xa6, + 0x08, 0x90, 0xc0, 0xba, 0x38, 0xaf, 0xc6, 0x8a, 0x63, 0x1b, 0xdf, 0xb9, 0x5a, 0x24, 0x7e, 0x43, + 0xe2, 0x6f, 0xe0, 0xcf, 0x45, 0xbe, 0x3b, 0xbb, 0x49, 0xf0, 0x50, 0xa7, 0xfd, 0x66, 0xbf, 0xef, + 0xbb, 0xef, 0x7d, 0x7e, 0xdf, 0x5d, 0x2e, 0xd0, 0xbb, 0x09, 0x16, 0x02, 0xfd, 0x69, 0xd0, 0x67, + 0xd3, 0xb9, 0x1f, 0xf6, 0x99, 0x87, 0xa1, 0xb0, 0xe2, 0x24, 0x12, 0x11, 0xd9, 0xc9, 0x31, 0x4b, + 0x62, 0xbd, 0x27, 0x05, 0xd7, 0x8d, 0x12, 0xec, 0x07, 0xbe, 0xc0, 0x84, 0x05, 0x5c, 0xb1, 0x7b, + 0x7b, 0xab, 0xa8, 0x60, 0x7c, 0x96, 0x43, 0x1f, 0xaf, 0x42, 0x7e, 0x28, 0x30, 0xb9, 0x61, 0x2e, + 0x6a, 0xf8, 0x93, 0x35, 0x78, 0x8a, 0xa1, 0xf0, 0x6f, 0x7c, 0x4c, 0xca, 0x97, 0xe3, 0x1b, 0x74, + 0x53, 0xe1, 0x47, 0xa1, 0x82, 0xcd, 0x7f, 0xea, 0xd0, 0x1d, 0x33, 0x3e, 0xb3, 0xf3, 0xfa, 0x05, + 0x0a, 0x36, 0x65, 0x82, 0x11, 0x0a, 0x9d, 0xcc, 0x86, 0x53, 0xac, 0x70, 0xfc, 0xa9, 0x51, 0xd9, + 0xaf, 0x1c, 0xb4, 0x0e, 0x3f, 0xb3, 0x8a, 0x8f, 0xcb, 0x44, 0xad, 0x15, 0x81, 0xf3, 0xc2, 0x01, + 0x7d, 0x28, 0x56, 0x01, 0xf2, 0x04, 0x9a, 0x21, 0x9b, 0x23, 0x8f, 0x99, 0x8b, 0x46, 0x75, 0xbf, + 0x72, 0xd0, 0xa4, 0x77, 0x05, 0x72, 0x0e, 0x9b, 0x01, 0x9b, 0x60, 0xc0, 0x8d, 0xda, 0x7e, 0xed, + 0xa0, 0x75, 0xf8, 0xc2, 0x5a, 0x9d, 0xa1, 0x55, 0x6a, 0xd4, 0x1a, 0xca, 0x35, 0x76, 0x28, 0x92, + 0x05, 0xd5, 0x02, 0xe4, 0x27, 0x68, 0xb1, 0x30, 0x8c, 0x04, 0xcb, 0x98, 0xdc, 0xd8, 0x90, 0x7a, + 0x5f, 0xdd, 0x4f, 0x6f, 0x70, 0xb7, 0x50, 0x89, 0x2e, 0x4b, 0x11, 0x0b, 0x1e, 0xcd, 0x8e, 0xb9, + 0xc3, 0x31, 0xb9, 0xf5, 0x5d, 0x74, 0x98, 0xeb, 0x46, 0x69, 0x28, 0x8c, 0xba, 0xfc, 0x98, 0xce, + 0xec, 0x98, 0x5f, 0x29, 0x64, 0xa0, 0x00, 0x22, 0xa0, 0x8b, 0xe1, 0xad, 0x9f, 0x44, 0xe1, 0x1c, + 0x43, 0xe1, 0xdc, 0xb2, 0xc4, 0x67, 0x93, 0x00, 0xb9, 0xb1, 0x29, 0x3d, 0xbd, 0xba, 0x9f, 0x27, + 0xfb, 0x4e, 0xe2, 0xc7, 0x5c, 0x41, 0x99, 0xdb, 0xc5, 0x12, 0xa8, 0xf7, 0x12, 0x5a, 0x4b, 0x63, + 0x21, 0x6d, 0xa8, 0xcd, 0x70, 0x21, 0xd3, 0x6b, 0xd2, 0xec, 0x91, 0xec, 0x42, 0xfd, 0x96, 0x05, + 0x69, 0x9e, 0x82, 0x7a, 0xf9, 0xa6, 0x7a, 0x5c, 0xe9, 0x7d, 0x0f, 0xed, 0xf5, 0x09, 0xbc, 0xd3, + 0xfa, 0x33, 0xd8, 0x7b, 0xab, 0xdb, 0x77, 0x11, 0x32, 0xff, 0xaa, 0x42, 0xe7, 0x24, 0x41, 0x26, + 0x30, 0x9b, 0x09, 0xc5, 0x3f, 0x52, 0xe4, 0x82, 0xbc, 0x80, 0x4d, 0x3f, 0x8c, 0x53, 0xc1, 0xf5, + 0x5e, 0xdc, 0x5b, 0xdb, 0x8b, 0x43, 0x75, 0xb0, 0x2e, 0x58, 0x4c, 0x35, 0x91, 0x7c, 0x0d, 0x0d, + 0x81, 0xf3, 0x38, 0x60, 0x42, 0x75, 0x69, 0x1d, 0x3e, 0x2e, 0xd9, 0xc0, 0x63, 0x4d, 0xa1, 0x05, + 0x99, 0x7c, 0x0a, 0x0f, 0xa2, 0x54, 0xc4, 0xa9, 0x70, 0xe2, 0x04, 0x6f, 0xfc, 0x37, 0x46, 0x4d, + 0x7a, 0xdc, 0x56, 0xc5, 0x4b, 0x59, 0x23, 0xbf, 0xc2, 0x47, 0x6b, 0xe7, 0x64, 0xae, 0x53, 0x33, + 0x36, 0x64, 0xb3, 0xa7, 0xf7, 0x8a, 0x98, 0x76, 0x45, 0x59, 0xd9, 0x7c, 0x09, 0x64, 0x79, 0x08, + 0x3c, 0x8e, 0x42, 0x2e, 0x9d, 0x25, 0xc8, 0xa3, 0x34, 0x71, 0x51, 0xb6, 0x93, 0xc3, 0xd8, 0xa6, + 0xdb, 0x79, 0x31, 0x5b, 0x6e, 0x52, 0xd8, 0x39, 0x43, 0xb1, 0x3c, 0xbc, 0xc7, 0xd0, 0x94, 0x5e, + 0xc5, 0x22, 0x46, 0x1d, 0x42, 0x23, 0x2b, 0x8c, 0x17, 0x71, 0x89, 0x66, 0xb5, 0x44, 0xf3, 0x4f, + 0x78, 0x58, 0x68, 0x6a, 0x2f, 0x5f, 0x42, 0x23, 0xa7, 0xe8, 0x4c, 0x8c, 0xf5, 0x2f, 0xa6, 0x1a, + 0xa7, 0x05, 0x93, 0x1c, 0x41, 0x33, 0x88, 0x3c, 0x27, 0xf0, 0xc3, 0x19, 0x37, 0xaa, 0xf2, 0x2c, + 0x7c, 0x58, 0x92, 0xca, 0x30, 0xf2, 0x68, 0x23, 0x88, 0xbc, 0x61, 0xc6, 0x33, 0xff, 0xae, 0x40, + 0x23, 0xd7, 0x22, 0xcf, 0xa0, 0xce, 0x45, 0x96, 0x69, 0xd6, 0x74, 0xe7, 0xb0, 0xbb, 0xde, 0xf4, + 0x2a, 0x03, 0xa9, 0xe2, 0x90, 0x23, 0xd8, 0x52, 0xa9, 0x71, 0xbd, 0x05, 0xfe, 0x67, 0xdf, 0xe4, + 0x4c, 0x62, 0xc0, 0xd6, 0x1c, 0x39, 0x67, 0x1e, 0xea, 0xe4, 0xf3, 0x57, 0xf3, 0x1a, 0x3a, 0xa7, + 0x18, 0xe0, 0xea, 0xd6, 0x7c, 0xff, 0xe9, 0xee, 0x02, 0x59, 0x96, 0x55, 0x03, 0x36, 0x2f, 0xa0, + 0x3e, 0xc8, 0x6e, 0x16, 0x42, 0x60, 0x23, 0xfb, 0xb5, 0xd4, 0xda, 0xf2, 0x99, 0x7c, 0x01, 0xbb, + 0x3c, 0x8d, 0xe3, 0x28, 0x11, 0x38, 0x75, 0x8a, 0xf6, 0x6a, 0xa4, 0x4d, 0x4a, 0x0a, 0x6c, 0xac, + 0x8d, 0x70, 0xf3, 0xa9, 0x8c, 0x50, 0x2a, 0xe6, 0xce, 0x4b, 0x84, 0xcd, 0x57, 0xd0, 0xbe, 0xa3, + 0xe9, 0xa8, 0x9f, 0x41, 0x5d, 0xde, 0x71, 0x3a, 0xe7, 0xff, 0x8c, 0x5c, 0xb1, 0x15, 0xc7, 0x7c, + 0x04, 0x9d, 0xa1, 0xcf, 0x95, 0x02, 0xd7, 0x9d, 0xcc, 0x13, 0x20, 0xcb, 0x45, 0xad, 0xfb, 0x1c, + 0x36, 0xe5, 0x9a, 0xec, 0x50, 0xd7, 0xde, 0x2e, 0xac, 0x49, 0x9f, 0xff, 0x06, 0x75, 0x19, 0x2e, + 0xe9, 0x42, 0x87, 0xda, 0x63, 0xfa, 0xf3, 0xe0, 0xf5, 0xd0, 0x76, 0x7e, 0x18, 0x9c, 0x0f, 0xaf, + 0xa9, 0xdd, 0xfe, 0x20, 0x2b, 0x5f, 0xda, 0xf4, 0x62, 0x30, 0xb2, 0x47, 0xe3, 0xa2, 0x5c, 0x21, + 0x2d, 0xd8, 0xba, 0xb4, 0x47, 0xa7, 0xe7, 0xa3, 0xb3, 0x76, 0x35, 0x7b, 0xa1, 0xd7, 0xa3, 0x51, + 0xf6, 0x52, 0x23, 0x0f, 0xa0, 0x79, 0x75, 0x7d, 0x72, 0x62, 0xdb, 0xa7, 0xf6, 0x69, 0x7b, 0xe3, + 0xf5, 0x77, 0xbf, 0x7c, 0xeb, 0xf9, 0xe2, 0xf7, 0x74, 0x62, 0xb9, 0xd1, 0xbc, 0x2f, 0xad, 0x44, + 0x89, 0xa7, 0x1e, 0xfa, 0xc5, 0x7d, 0xea, 0x61, 0xd8, 0x8f, 0x27, 0xcf, 0xbd, 0xa8, 0xbf, 0xfa, + 0x37, 0x60, 0xb2, 0x29, 0xaf, 0xd6, 0xa3, 0x7f, 0x03, 0x00, 0x00, 0xff, 0xff, 0x81, 0xa7, 0x12, + 0x0e, 0x1f, 0x08, 0x00, 0x00, } diff --git a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.validate.go b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.validate.go index fa6dbe6adb..c4767d006c 100644 --- a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.validate.go +++ b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.validate.go @@ -675,8 +675,6 @@ func (m *Agent) Validate() error { // no validation rules for Name - // no validation rules for IsSync - return nil } diff --git a/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json b/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json index ea6db19960..ce431a28ef 100644 --- a/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json +++ b/flyteidl/gen/pb-go/flyteidl/service/agent.swagger.json @@ -229,11 +229,6 @@ "type": "string" }, "description": "SupportedTaskTypes are the types of the tasks that the agent can handle." - }, - "is_sync": { - "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." } }, "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 716c2079ff..a6fa424d2a 100644 --- a/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java +++ b/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java @@ -8046,15 +8046,6 @@ public interface AgentOrBuilder extends */ com.google.protobuf.ByteString getSupportedTaskTypesBytes(int index); - - /** - *
-     * 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; - */ - boolean getIsSync(); } /** *
@@ -8116,11 +8107,6 @@ private Agent(
               supportedTaskTypes_.add(s);
               break;
             }
-            case 24: {
-
-              isSync_ = input.readBool();
-              break;
-            }
             default: {
               if (!parseUnknownField(
                   input, unknownFields, extensionRegistry, tag)) {
@@ -8244,19 +8230,6 @@ public java.lang.String getSupportedTaskTypes(int index) {
       return supportedTaskTypes_.getByteString(index);
     }
 
-    public static final int IS_SYNC_FIELD_NUMBER = 3;
-    private boolean isSync_;
-    /**
-     * 
-     * 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; - */ - public boolean getIsSync() { - return isSync_; - } - private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -8277,9 +8250,6 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) for (int i = 0; i < supportedTaskTypes_.size(); i++) { com.google.protobuf.GeneratedMessageV3.writeString(output, 2, supportedTaskTypes_.getRaw(i)); } - if (isSync_ != false) { - output.writeBool(3, isSync_); - } unknownFields.writeTo(output); } @@ -8300,10 +8270,6 @@ public int getSerializedSize() { size += dataSize; size += 1 * getSupportedTaskTypesList().size(); } - if (isSync_ != false) { - size += com.google.protobuf.CodedOutputStream - .computeBoolSize(3, isSync_); - } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -8323,8 +8289,6 @@ public boolean equals(final java.lang.Object obj) { .equals(other.getName())) return false; if (!getSupportedTaskTypesList() .equals(other.getSupportedTaskTypesList())) return false; - if (getIsSync() - != other.getIsSync()) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -8342,9 +8306,6 @@ public int hashCode() { hash = (37 * hash) + SUPPORTED_TASK_TYPES_FIELD_NUMBER; hash = (53 * hash) + getSupportedTaskTypesList().hashCode(); } - hash = (37 * hash) + IS_SYNC_FIELD_NUMBER; - hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( - getIsSync()); hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -8486,8 +8447,6 @@ public Builder clear() { supportedTaskTypes_ = com.google.protobuf.LazyStringArrayList.EMPTY; bitField0_ = (bitField0_ & ~0x00000002); - isSync_ = false; - return this; } @@ -8522,7 +8481,6 @@ public flyteidl.admin.AgentOuterClass.Agent buildPartial() { bitField0_ = (bitField0_ & ~0x00000002); } result.supportedTaskTypes_ = supportedTaskTypes_; - result.isSync_ = isSync_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -8586,9 +8544,6 @@ public Builder mergeFrom(flyteidl.admin.AgentOuterClass.Agent other) { } onChanged(); } - if (other.getIsSync() != false) { - setIsSync(other.getIsSync()); - } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -8837,44 +8792,6 @@ public Builder addSupportedTaskTypesBytes( onChanged(); return this; } - - private boolean isSync_ ; - /** - *
-       * 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; - */ - public boolean getIsSync() { - return isSync_; - } - /** - *
-       * 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; - */ - public Builder setIsSync(boolean value) { - - isSync_ = value; - onChanged(); - return this; - } - /** - *
-       * 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; - */ - public Builder clearIsSync() { - - isSync_ = false; - onChanged(); - return this; - } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -11465,17 +11382,17 @@ public flyteidl.admin.AgentOuterClass.ListAgentsResponse getDefaultInstanceForTy "tate\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core.Li" + "teralMap\022\017\n\007message\030\003 \001(\t\"=\n\021DeleteTaskR" + "equest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_me" + - "ta\030\002 \001(\014\"\024\n\022DeleteTaskResponse\"D\n\005Agent\022" + + "ta\030\002 \001(\014\"\024\n\022DeleteTaskResponse\"3\n\005Agent\022" + "\014\n\004name\030\001 \001(\t\022\034\n\024supported_task_types\030\002 " + - "\003(\t\022\017\n\007is_sync\030\003 \001(\010\"\037\n\017GetAgentRequest\022" + - "\014\n\004name\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005age" + - "nt\030\001 \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListA" + - "gentsRequest\";\n\022ListAgentsResponse\022%\n\006ag" + - "ents\030\001 \003(\0132\025.flyteidl.admin.Agent*^\n\005Sta" + - "te\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021PERMANENT_F" + - "AILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSU" + - "CCEEDED\020\004B=Z;github.com/flyteorg/flyte/f" + - "lyteidl/gen/pb-go/flyteidl/adminb\006proto3" + "\003(\t\"\037\n\017GetAgentRequest\022\014\n\004name\030\001 \001(\t\"8\n\020" + + "GetAgentResponse\022$\n\005agent\030\001 \001(\0132\025.flytei" + + "dl.admin.Agent\"\023\n\021ListAgentsRequest\";\n\022L" + + "istAgentsResponse\022%\n\006agents\030\001 \003(\0132\025.flyt" + + "eidl.admin.Agent*^\n\005State\022\025\n\021RETRYABLE_F" + + "AILURE\020\000\022\025\n\021PERMANENT_FAILURE\020\001\022\013\n\007PENDI" + + "NG\020\002\022\013\n\007RUNNING\020\003\022\r\n\tSUCCEEDED\020\004B=Z;gith" + + "ub.com/flyteorg/flyte/flyteidl/gen/pb-go" + + "/flyteidl/adminb\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { @@ -11565,7 +11482,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", }); + new java.lang.String[] { "Name", "SupportedTaskTypes", }); 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 12f0beed20..b55b84894a 100644 --- a/flyteidl/gen/pb-js/flyteidl.d.ts +++ b/flyteidl/gen/pb-js/flyteidl.d.ts @@ -8361,9 +8361,6 @@ export namespace flyteidl { /** Agent supportedTaskTypes */ supportedTaskTypes?: (string[]|null); - - /** Agent isSync */ - isSync?: (boolean|null); } /** Represents an Agent. */ @@ -8381,9 +8378,6 @@ export namespace flyteidl { /** Agent supportedTaskTypes. */ public supportedTaskTypes: string[]; - /** Agent isSync. */ - public isSync: boolean; - /** * 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 9c0f7c5564..6845a64bbc 100644 --- a/flyteidl/gen/pb-js/flyteidl.js +++ b/flyteidl/gen/pb-js/flyteidl.js @@ -20389,7 +20389,6 @@ * @interface IAgent * @property {string|null} [name] Agent name * @property {Array.|null} [supportedTaskTypes] Agent supportedTaskTypes - * @property {boolean|null} [isSync] Agent isSync */ /** @@ -20424,14 +20423,6 @@ */ Agent.prototype.supportedTaskTypes = $util.emptyArray; - /** - * Agent isSync. - * @member {boolean} isSync - * @memberof flyteidl.admin.Agent - * @instance - */ - Agent.prototype.isSync = false; - /** * Creates a new Agent instance using the specified properties. * @function create @@ -20461,8 +20452,6 @@ if (message.supportedTaskTypes != null && message.supportedTaskTypes.length) for (var i = 0; i < message.supportedTaskTypes.length; ++i) 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); return writer; }; @@ -20492,9 +20481,6 @@ message.supportedTaskTypes = []; message.supportedTaskTypes.push(reader.string()); break; - case 3: - message.isSync = reader.bool(); - break; default: reader.skipType(tag & 7); break; @@ -20524,9 +20510,6 @@ if (!$util.isString(message.supportedTaskTypes[i])) return "supportedTaskTypes: string[] expected"; } - if (message.isSync != null && message.hasOwnProperty("isSync")) - if (typeof message.isSync !== "boolean") - return "isSync: boolean 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 b103dd1598..baceaf16c6 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\"\x83\x02\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\"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') +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\"\x83\x02\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\"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\"M\n\x05\x41gent\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x30\n\x14supported_task_types\x18\x02 \x03(\tR\x12supportedTaskTypes\"%\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) @@ -33,8 +33,8 @@ _TASKEXECUTIONMETADATA_ANNOTATIONSENTRY._serialized_options = b'8\001' _TASKEXECUTIONMETADATA_ENVIRONMENTVARIABLESENTRY._options = None _TASKEXECUTIONMETADATA_ENVIRONMENTVARIABLESENTRY._serialized_options = b'8\001' - _globals['_STATE']._serialized_start=1939 - _globals['_STATE']._serialized_end=2033 + _globals['_STATE']._serialized_start=1914 + _globals['_STATE']._serialized_end=2008 _globals['_TASKEXECUTIONMETADATA']._serialized_start=198 _globals['_TASKEXECUTIONMETADATA']._serialized_end=862 _globals['_TASKEXECUTIONMETADATA_LABELSENTRY']._serialized_start=668 @@ -58,13 +58,13 @@ _globals['_DELETETASKRESPONSE']._serialized_start=1619 _globals['_DELETETASKRESPONSE']._serialized_end=1639 _globals['_AGENT']._serialized_start=1641 - _globals['_AGENT']._serialized_end=1743 - _globals['_GETAGENTREQUEST']._serialized_start=1745 - _globals['_GETAGENTREQUEST']._serialized_end=1782 - _globals['_GETAGENTRESPONSE']._serialized_start=1784 - _globals['_GETAGENTRESPONSE']._serialized_end=1847 - _globals['_LISTAGENTSREQUEST']._serialized_start=1849 - _globals['_LISTAGENTSREQUEST']._serialized_end=1868 - _globals['_LISTAGENTSRESPONSE']._serialized_start=1870 - _globals['_LISTAGENTSRESPONSE']._serialized_end=1937 + _globals['_AGENT']._serialized_end=1718 + _globals['_GETAGENTREQUEST']._serialized_start=1720 + _globals['_GETAGENTREQUEST']._serialized_end=1757 + _globals['_GETAGENTRESPONSE']._serialized_start=1759 + _globals['_GETAGENTRESPONSE']._serialized_end=1822 + _globals['_LISTAGENTSREQUEST']._serialized_start=1824 + _globals['_LISTAGENTSREQUEST']._serialized_end=1843 + _globals['_LISTAGENTSRESPONSE']._serialized_start=1845 + _globals['_LISTAGENTSRESPONSE']._serialized_end=1912 # @@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 d224a51ad5..d184c997b7 100644 --- a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi +++ b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.pyi @@ -118,14 +118,12 @@ class DeleteTaskResponse(_message.Message): def __init__(self) -> None: ... class Agent(_message.Message): - __slots__ = ["name", "supported_task_types", "is_sync"] + __slots__ = ["name", "supported_task_types"] NAME_FIELD_NUMBER: _ClassVar[int] SUPPORTED_TASK_TYPES_FIELD_NUMBER: _ClassVar[int] - IS_SYNC_FIELD_NUMBER: _ClassVar[int] name: str supported_task_types: _containers.RepeatedScalarFieldContainer[str] - is_sync: bool - def __init__(self, name: _Optional[str] = ..., supported_task_types: _Optional[_Iterable[str]] = ..., is_sync: bool = ...) -> None: ... + def __init__(self, name: _Optional[str] = ..., supported_task_types: _Optional[_Iterable[str]] = ...) -> 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 237ee648ab..3758f6d90e 100644 --- a/flyteidl/gen/pb_rust/flyteidl.admin.rs +++ b/flyteidl/gen/pb_rust/flyteidl.admin.rs @@ -111,9 +111,6 @@ pub struct Agent { /// SupportedTaskTypes are the types of the tasks that the agent can handle. #[prost(string, repeated, tag="2")] pub supported_task_types: ::prost::alloc::vec::Vec<::prost::alloc::string::String>, - /// 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, } /// 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 9c69d733eb..98ab21cd07 100644 --- a/flyteidl/protos/flyteidl/admin/agent.proto +++ b/flyteidl/protos/flyteidl/admin/agent.proto @@ -99,9 +99,6 @@ message Agent { // SupportedTaskTypes are the types of the tasks that the agent can handle. repeated string supported_task_types = 2; - - // 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; } // A request to get an agent.