From 5b1576d59695cdf41102d2dcc398390075ce3371 Mon Sep 17 00:00:00 2001 From: Katrina Rogan Date: Mon, 3 Jan 2022 17:44:13 -0800 Subject: [PATCH] Add incompatible cluster event error (#240) --- .../gen/pb-cpp/flyteidl/admin/event.pb.cc | 467 +++++++++- flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.h | 252 ++++- flyteidl/gen/pb-go/flyteidl/admin/event.pb.go | 123 ++- .../pb-go/flyteidl/admin/event.pb.validate.go | 82 ++ .../gen/pb-java/flyteidl/admin/Event.java | 880 +++++++++++++++++- flyteidl/gen/pb-js/flyteidl.d.ts | 60 +- flyteidl/gen/pb-js/flyteidl.js | 138 ++- .../gen/pb_python/flyteidl/admin/event_pb2.py | 80 +- flyteidl/protos/docs/admin/admin.rst | 23 + flyteidl/protos/flyteidl/admin/event.proto | 9 + 10 files changed, 2009 insertions(+), 105 deletions(-) diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.cc index 526f89c1c5..1d1100c3f6 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.cc +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.cc @@ -17,6 +17,7 @@ #include extern PROTOBUF_INTERNAL_EXPORT_flyteidl_2fadmin_2fevent_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_EventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto; +extern PROTOBUF_INTERNAL_EXPORT_flyteidl_2fadmin_2fevent_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto; extern PROTOBUF_INTERNAL_EXPORT_flyteidl_2fevent_2fevent_2eproto ::google::protobuf::internal::SCCInfo<4> scc_info_WorkflowExecutionEvent_flyteidl_2fevent_2fevent_2eproto; extern PROTOBUF_INTERNAL_EXPORT_flyteidl_2fevent_2fevent_2eproto ::google::protobuf::internal::SCCInfo<8> scc_info_NodeExecutionEvent_flyteidl_2fevent_2fevent_2eproto; extern PROTOBUF_INTERNAL_EXPORT_flyteidl_2fevent_2fevent_2eproto ::google::protobuf::internal::SCCInfo<8> scc_info_TaskExecutionEvent_flyteidl_2fevent_2fevent_2eproto; @@ -26,10 +27,15 @@ class EventErrorAlreadyInTerminalStateDefaultTypeInternal { public: ::google::protobuf::internal::ExplicitlyConstructed _instance; } _EventErrorAlreadyInTerminalState_default_instance_; +class EventErrorIncompatibleClusterDefaultTypeInternal { + public: + ::google::protobuf::internal::ExplicitlyConstructed _instance; +} _EventErrorIncompatibleCluster_default_instance_; class EventFailureReasonDefaultTypeInternal { public: ::google::protobuf::internal::ExplicitlyConstructed _instance; const ::flyteidl::admin::EventErrorAlreadyInTerminalState* already_in_terminal_state_; + const ::flyteidl::admin::EventErrorIncompatibleCluster* incompatible_cluster_; } _EventFailureReason_default_instance_; class WorkflowExecutionEventRequestDefaultTypeInternal { public: @@ -71,6 +77,20 @@ static void InitDefaultsEventErrorAlreadyInTerminalState_flyteidl_2fadmin_2feven ::google::protobuf::internal::SCCInfo<0> scc_info_EventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto = {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsEventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto}, {}}; +static void InitDefaultsEventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto() { + GOOGLE_PROTOBUF_VERIFY_VERSION; + + { + void* ptr = &::flyteidl::admin::_EventErrorIncompatibleCluster_default_instance_; + new (ptr) ::flyteidl::admin::EventErrorIncompatibleCluster(); + ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); + } + ::flyteidl::admin::EventErrorIncompatibleCluster::InitAsDefaultInstance(); +} + +::google::protobuf::internal::SCCInfo<0> scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto = + {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsEventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto}, {}}; + static void InitDefaultsEventFailureReason_flyteidl_2fadmin_2fevent_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; @@ -82,9 +102,10 @@ static void InitDefaultsEventFailureReason_flyteidl_2fadmin_2fevent_2eproto() { ::flyteidl::admin::EventFailureReason::InitAsDefaultInstance(); } -::google::protobuf::internal::SCCInfo<1> scc_info_EventFailureReason_flyteidl_2fadmin_2fevent_2eproto = - {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsEventFailureReason_flyteidl_2fadmin_2fevent_2eproto}, { - &scc_info_EventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto.base,}}; +::google::protobuf::internal::SCCInfo<2> scc_info_EventFailureReason_flyteidl_2fadmin_2fevent_2eproto = + {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 2, InitDefaultsEventFailureReason_flyteidl_2fadmin_2fevent_2eproto}, { + &scc_info_EventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto.base, + &scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto.base,}}; static void InitDefaultsWorkflowExecutionEventRequest_flyteidl_2fadmin_2fevent_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; @@ -175,6 +196,7 @@ ::google::protobuf::internal::SCCInfo<0> scc_info_TaskExecutionEventResponse_fly void InitDefaults_flyteidl_2fadmin_2fevent_2eproto() { ::google::protobuf::internal::InitSCC(&scc_info_EventErrorAlreadyInTerminalState_flyteidl_2fadmin_2fevent_2eproto.base); + ::google::protobuf::internal::InitSCC(&scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto.base); ::google::protobuf::internal::InitSCC(&scc_info_EventFailureReason_flyteidl_2fadmin_2fevent_2eproto.base); ::google::protobuf::internal::InitSCC(&scc_info_WorkflowExecutionEventRequest_flyteidl_2fadmin_2fevent_2eproto.base); ::google::protobuf::internal::InitSCC(&scc_info_WorkflowExecutionEventResponse_flyteidl_2fadmin_2fevent_2eproto.base); @@ -184,7 +206,7 @@ void InitDefaults_flyteidl_2fadmin_2fevent_2eproto() { ::google::protobuf::internal::InitSCC(&scc_info_TaskExecutionEventResponse_flyteidl_2fadmin_2fevent_2eproto.base); } -::google::protobuf::Metadata file_level_metadata_flyteidl_2fadmin_2fevent_2eproto[8]; +::google::protobuf::Metadata file_level_metadata_flyteidl_2fadmin_2fevent_2eproto[9]; constexpr ::google::protobuf::EnumDescriptor const** file_level_enum_descriptors_flyteidl_2fadmin_2fevent_2eproto = nullptr; constexpr ::google::protobuf::ServiceDescriptor const** file_level_service_descriptors_flyteidl_2fadmin_2fevent_2eproto = nullptr; @@ -196,11 +218,18 @@ const ::google::protobuf::uint32 TableStruct_flyteidl_2fadmin_2fevent_2eproto::o ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventErrorAlreadyInTerminalState, current_phase_), ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventErrorIncompatibleCluster, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventErrorIncompatibleCluster, cluster_), + ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventFailureReason, _internal_metadata_), ~0u, // no _extensions_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventFailureReason, _oneof_case_[0]), ~0u, // no _weak_field_map_ offsetof(::flyteidl::admin::EventFailureReasonDefaultTypeInternal, already_in_terminal_state_), + offsetof(::flyteidl::admin::EventFailureReasonDefaultTypeInternal, incompatible_cluster_), PROTOBUF_FIELD_OFFSET(::flyteidl::admin::EventFailureReason, reason_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::flyteidl::admin::WorkflowExecutionEventRequest, _internal_metadata_), @@ -241,17 +270,19 @@ const ::google::protobuf::uint32 TableStruct_flyteidl_2fadmin_2fevent_2eproto::o }; static const ::google::protobuf::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { { 0, -1, sizeof(::flyteidl::admin::EventErrorAlreadyInTerminalState)}, - { 6, -1, sizeof(::flyteidl::admin::EventFailureReason)}, - { 13, -1, sizeof(::flyteidl::admin::WorkflowExecutionEventRequest)}, - { 20, -1, sizeof(::flyteidl::admin::WorkflowExecutionEventResponse)}, - { 25, -1, sizeof(::flyteidl::admin::NodeExecutionEventRequest)}, - { 32, -1, sizeof(::flyteidl::admin::NodeExecutionEventResponse)}, - { 37, -1, sizeof(::flyteidl::admin::TaskExecutionEventRequest)}, - { 44, -1, sizeof(::flyteidl::admin::TaskExecutionEventResponse)}, + { 6, -1, sizeof(::flyteidl::admin::EventErrorIncompatibleCluster)}, + { 12, -1, sizeof(::flyteidl::admin::EventFailureReason)}, + { 20, -1, sizeof(::flyteidl::admin::WorkflowExecutionEventRequest)}, + { 27, -1, sizeof(::flyteidl::admin::WorkflowExecutionEventResponse)}, + { 32, -1, sizeof(::flyteidl::admin::NodeExecutionEventRequest)}, + { 39, -1, sizeof(::flyteidl::admin::NodeExecutionEventResponse)}, + { 44, -1, sizeof(::flyteidl::admin::TaskExecutionEventRequest)}, + { 51, -1, sizeof(::flyteidl::admin::TaskExecutionEventResponse)}, }; static ::google::protobuf::Message const * const file_default_instances[] = { reinterpret_cast(&::flyteidl::admin::_EventErrorAlreadyInTerminalState_default_instance_), + reinterpret_cast(&::flyteidl::admin::_EventErrorIncompatibleCluster_default_instance_), reinterpret_cast(&::flyteidl::admin::_EventFailureReason_default_instance_), reinterpret_cast(&::flyteidl::admin::_WorkflowExecutionEventRequest_default_instance_), reinterpret_cast(&::flyteidl::admin::_WorkflowExecutionEventResponse_default_instance_), @@ -264,33 +295,37 @@ static ::google::protobuf::Message const * const file_default_instances[] = { ::google::protobuf::internal::AssignDescriptorsTable assign_descriptors_table_flyteidl_2fadmin_2fevent_2eproto = { {}, AddDescriptors_flyteidl_2fadmin_2fevent_2eproto, "flyteidl/admin/event.proto", schemas, file_default_instances, TableStruct_flyteidl_2fadmin_2fevent_2eproto::offsets, - file_level_metadata_flyteidl_2fadmin_2fevent_2eproto, 8, file_level_enum_descriptors_flyteidl_2fadmin_2fevent_2eproto, file_level_service_descriptors_flyteidl_2fadmin_2fevent_2eproto, + file_level_metadata_flyteidl_2fadmin_2fevent_2eproto, 9, file_level_enum_descriptors_flyteidl_2fadmin_2fevent_2eproto, file_level_service_descriptors_flyteidl_2fadmin_2fevent_2eproto, }; const char descriptor_table_protodef_flyteidl_2fadmin_2fevent_2eproto[] = "\n\032flyteidl/admin/event.proto\022\016flyteidl.a" "dmin\032\032flyteidl/event/event.proto\"9\n Even" "tErrorAlreadyInTerminalState\022\025\n\rcurrent_" - "phase\030\001 \001(\t\"u\n\022EventFailureReason\022U\n\031alr" - "eady_in_terminal_state\030\001 \001(\01320.flyteidl." - "admin.EventErrorAlreadyInTerminalStateH\000" - "B\010\n\006reason\"j\n\035WorkflowExecutionEventRequ" - "est\022\022\n\nrequest_id\030\001 \001(\t\0225\n\005event\030\002 \001(\0132&" - ".flyteidl.event.WorkflowExecutionEvent\" " - "\n\036WorkflowExecutionEventResponse\"b\n\031Node" - "ExecutionEventRequest\022\022\n\nrequest_id\030\001 \001(" - "\t\0221\n\005event\030\002 \001(\0132\".flyteidl.event.NodeEx" - "ecutionEvent\"\034\n\032NodeExecutionEventRespon" - "se\"b\n\031TaskExecutionEventRequest\022\022\n\nreque" + "phase\030\001 \001(\t\"0\n\035EventErrorIncompatibleClu" + "ster\022\017\n\007cluster\030\001 \001(\t\"\304\001\n\022EventFailureRe" + "ason\022U\n\031already_in_terminal_state\030\001 \001(\0132" + "0.flyteidl.admin.EventErrorAlreadyInTerm" + "inalStateH\000\022M\n\024incompatible_cluster\030\002 \001(" + "\0132-.flyteidl.admin.EventErrorIncompatibl" + "eClusterH\000B\010\n\006reason\"j\n\035WorkflowExecutio" + "nEventRequest\022\022\n\nrequest_id\030\001 \001(\t\0225\n\005eve" + "nt\030\002 \001(\0132&.flyteidl.event.WorkflowExecut" + "ionEvent\" \n\036WorkflowExecutionEventRespon" + "se\"b\n\031NodeExecutionEventRequest\022\022\n\nreque" "st_id\030\001 \001(\t\0221\n\005event\030\002 \001(\0132\".flyteidl.ev" - "ent.TaskExecutionEvent\"\034\n\032TaskExecutionE" - "ventResponseB7Z5github.com/flyteorg/flyt" - "eidl/gen/pb-go/flyteidl/adminb\006proto3" + "ent.NodeExecutionEvent\"\034\n\032NodeExecutionE" + "ventResponse\"b\n\031TaskExecutionEventReques" + "t\022\022\n\nrequest_id\030\001 \001(\t\0221\n\005event\030\002 \001(\0132\".f" + "lyteidl.event.TaskExecutionEvent\"\034\n\032Task" + "ExecutionEventResponseB7Z5github.com/fly" + "teorg/flyteidl/gen/pb-go/flyteidl/adminb" + "\006proto3" ; ::google::protobuf::internal::DescriptorTable descriptor_table_flyteidl_2fadmin_2fevent_2eproto = { false, InitDefaults_flyteidl_2fadmin_2fevent_2eproto, descriptor_table_protodef_flyteidl_2fadmin_2fevent_2eproto, - "flyteidl/admin/event.proto", &assign_descriptors_table_flyteidl_2fadmin_2fevent_2eproto, 717, + "flyteidl/admin/event.proto", &assign_descriptors_table_flyteidl_2fadmin_2fevent_2eproto, 847, }; void AddDescriptors_flyteidl_2fadmin_2fevent_2eproto() { @@ -603,21 +638,325 @@ ::google::protobuf::Metadata EventErrorAlreadyInTerminalState::GetMetadata() con } +// =================================================================== + +void EventErrorIncompatibleCluster::InitAsDefaultInstance() { +} +class EventErrorIncompatibleCluster::HasBitSetters { + public: +}; + +#if !defined(_MSC_VER) || _MSC_VER >= 1900 +const int EventErrorIncompatibleCluster::kClusterFieldNumber; +#endif // !defined(_MSC_VER) || _MSC_VER >= 1900 + +EventErrorIncompatibleCluster::EventErrorIncompatibleCluster() + : ::google::protobuf::Message(), _internal_metadata_(nullptr) { + SharedCtor(); + // @@protoc_insertion_point(constructor:flyteidl.admin.EventErrorIncompatibleCluster) +} +EventErrorIncompatibleCluster::EventErrorIncompatibleCluster(const EventErrorIncompatibleCluster& from) + : ::google::protobuf::Message(), + _internal_metadata_(nullptr) { + _internal_metadata_.MergeFrom(from._internal_metadata_); + cluster_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + if (from.cluster().size() > 0) { + cluster_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.cluster_); + } + // @@protoc_insertion_point(copy_constructor:flyteidl.admin.EventErrorIncompatibleCluster) +} + +void EventErrorIncompatibleCluster::SharedCtor() { + ::google::protobuf::internal::InitSCC( + &scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto.base); + cluster_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} + +EventErrorIncompatibleCluster::~EventErrorIncompatibleCluster() { + // @@protoc_insertion_point(destructor:flyteidl.admin.EventErrorIncompatibleCluster) + SharedDtor(); +} + +void EventErrorIncompatibleCluster::SharedDtor() { + cluster_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} + +void EventErrorIncompatibleCluster::SetCachedSize(int size) const { + _cached_size_.Set(size); +} +const EventErrorIncompatibleCluster& EventErrorIncompatibleCluster::default_instance() { + ::google::protobuf::internal::InitSCC(&::scc_info_EventErrorIncompatibleCluster_flyteidl_2fadmin_2fevent_2eproto.base); + return *internal_default_instance(); +} + + +void EventErrorIncompatibleCluster::Clear() { +// @@protoc_insertion_point(message_clear_start:flyteidl.admin.EventErrorIncompatibleCluster) + ::google::protobuf::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + cluster_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + _internal_metadata_.Clear(); +} + +#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER +const char* EventErrorIncompatibleCluster::_InternalParse(const char* begin, const char* end, void* object, + ::google::protobuf::internal::ParseContext* ctx) { + auto msg = static_cast(object); + ::google::protobuf::int32 size; (void)size; + int depth; (void)depth; + ::google::protobuf::uint32 tag; + ::google::protobuf::internal::ParseFunc parser_till_end; (void)parser_till_end; + auto ptr = begin; + while (ptr < end) { + ptr = ::google::protobuf::io::Parse32(ptr, &tag); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + switch (tag >> 3) { + // string cluster = 1; + case 1: { + if (static_cast<::google::protobuf::uint8>(tag) != 10) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + ctx->extra_parse_data().SetFieldName("flyteidl.admin.EventErrorIncompatibleCluster.cluster"); + object = msg->mutable_cluster(); + 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; + break; + } + default: { + handle_unusual: + if ((tag & 7) == 4 || tag == 0) { + ctx->EndGroup(tag); + return ptr; + } + auto res = UnknownFieldParse(tag, {_InternalParse, msg}, + ptr, end, msg->_internal_metadata_.mutable_unknown_fields(), ctx); + ptr = res.first; + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr != nullptr); + if (res.second) return ptr; + } + } // switch + } // while + return ptr; +string_till_end: + static_cast<::std::string*>(object)->clear(); + static_cast<::std::string*>(object)->reserve(size); + goto len_delim_till_end; +len_delim_till_end: + return ctx->StoreAndTailCall(ptr, end, {_InternalParse, msg}, + {parser_till_end, object}, size); +} +#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER +bool EventErrorIncompatibleCluster::MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) { +#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure + ::google::protobuf::uint32 tag; + // @@protoc_insertion_point(parse_start:flyteidl.admin.EventErrorIncompatibleCluster) + for (;;) { + ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); + tag = p.first; + if (!p.second) goto handle_unusual; + switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { + // string cluster = 1; + case 1: { + if (static_cast< ::google::protobuf::uint8>(tag) == (10 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_cluster())); + DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->cluster().data(), static_cast(this->cluster().length()), + ::google::protobuf::internal::WireFormatLite::PARSE, + "flyteidl.admin.EventErrorIncompatibleCluster.cluster")); + } else { + goto handle_unusual; + } + break; + } + + default: { + handle_unusual: + if (tag == 0) { + goto success; + } + DO_(::google::protobuf::internal::WireFormat::SkipField( + input, tag, _internal_metadata_.mutable_unknown_fields())); + break; + } + } + } +success: + // @@protoc_insertion_point(parse_success:flyteidl.admin.EventErrorIncompatibleCluster) + return true; +failure: + // @@protoc_insertion_point(parse_failure:flyteidl.admin.EventErrorIncompatibleCluster) + return false; +#undef DO_ +} +#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + +void EventErrorIncompatibleCluster::SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const { + // @@protoc_insertion_point(serialize_start:flyteidl.admin.EventErrorIncompatibleCluster) + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + // string cluster = 1; + if (this->cluster().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->cluster().data(), static_cast(this->cluster().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.admin.EventErrorIncompatibleCluster.cluster"); + ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( + 1, this->cluster(), output); + } + + if (_internal_metadata_.have_unknown_fields()) { + ::google::protobuf::internal::WireFormat::SerializeUnknownFields( + _internal_metadata_.unknown_fields(), output); + } + // @@protoc_insertion_point(serialize_end:flyteidl.admin.EventErrorIncompatibleCluster) +} + +::google::protobuf::uint8* EventErrorIncompatibleCluster::InternalSerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const { + // @@protoc_insertion_point(serialize_to_array_start:flyteidl.admin.EventErrorIncompatibleCluster) + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + // string cluster = 1; + if (this->cluster().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->cluster().data(), static_cast(this->cluster().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.admin.EventErrorIncompatibleCluster.cluster"); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 1, this->cluster(), target); + } + + if (_internal_metadata_.have_unknown_fields()) { + target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields(), target); + } + // @@protoc_insertion_point(serialize_to_array_end:flyteidl.admin.EventErrorIncompatibleCluster) + return target; +} + +size_t EventErrorIncompatibleCluster::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:flyteidl.admin.EventErrorIncompatibleCluster) + size_t total_size = 0; + + if (_internal_metadata_.have_unknown_fields()) { + total_size += + ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( + _internal_metadata_.unknown_fields()); + } + ::google::protobuf::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + // string cluster = 1; + if (this->cluster().size() > 0) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->cluster()); + } + + int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); + SetCachedSize(cached_size); + return total_size; +} + +void EventErrorIncompatibleCluster::MergeFrom(const ::google::protobuf::Message& from) { +// @@protoc_insertion_point(generalized_merge_from_start:flyteidl.admin.EventErrorIncompatibleCluster) + GOOGLE_DCHECK_NE(&from, this); + const EventErrorIncompatibleCluster* source = + ::google::protobuf::DynamicCastToGenerated( + &from); + if (source == nullptr) { + // @@protoc_insertion_point(generalized_merge_from_cast_fail:flyteidl.admin.EventErrorIncompatibleCluster) + ::google::protobuf::internal::ReflectionOps::Merge(from, this); + } else { + // @@protoc_insertion_point(generalized_merge_from_cast_success:flyteidl.admin.EventErrorIncompatibleCluster) + MergeFrom(*source); + } +} + +void EventErrorIncompatibleCluster::MergeFrom(const EventErrorIncompatibleCluster& from) { +// @@protoc_insertion_point(class_specific_merge_from_start:flyteidl.admin.EventErrorIncompatibleCluster) + GOOGLE_DCHECK_NE(&from, this); + _internal_metadata_.MergeFrom(from._internal_metadata_); + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + if (from.cluster().size() > 0) { + + cluster_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.cluster_); + } +} + +void EventErrorIncompatibleCluster::CopyFrom(const ::google::protobuf::Message& from) { +// @@protoc_insertion_point(generalized_copy_from_start:flyteidl.admin.EventErrorIncompatibleCluster) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +void EventErrorIncompatibleCluster::CopyFrom(const EventErrorIncompatibleCluster& from) { +// @@protoc_insertion_point(class_specific_copy_from_start:flyteidl.admin.EventErrorIncompatibleCluster) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool EventErrorIncompatibleCluster::IsInitialized() const { + return true; +} + +void EventErrorIncompatibleCluster::Swap(EventErrorIncompatibleCluster* other) { + if (other == this) return; + InternalSwap(other); +} +void EventErrorIncompatibleCluster::InternalSwap(EventErrorIncompatibleCluster* other) { + using std::swap; + _internal_metadata_.Swap(&other->_internal_metadata_); + cluster_.Swap(&other->cluster_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), + GetArenaNoVirtual()); +} + +::google::protobuf::Metadata EventErrorIncompatibleCluster::GetMetadata() const { + ::google::protobuf::internal::AssignDescriptors(&::assign_descriptors_table_flyteidl_2fadmin_2fevent_2eproto); + return ::file_level_metadata_flyteidl_2fadmin_2fevent_2eproto[kIndexInFileMessages]; +} + + // =================================================================== void EventFailureReason::InitAsDefaultInstance() { ::flyteidl::admin::_EventFailureReason_default_instance_.already_in_terminal_state_ = const_cast< ::flyteidl::admin::EventErrorAlreadyInTerminalState*>( ::flyteidl::admin::EventErrorAlreadyInTerminalState::internal_default_instance()); + ::flyteidl::admin::_EventFailureReason_default_instance_.incompatible_cluster_ = const_cast< ::flyteidl::admin::EventErrorIncompatibleCluster*>( + ::flyteidl::admin::EventErrorIncompatibleCluster::internal_default_instance()); } class EventFailureReason::HasBitSetters { public: static const ::flyteidl::admin::EventErrorAlreadyInTerminalState& already_in_terminal_state(const EventFailureReason* msg); + static const ::flyteidl::admin::EventErrorIncompatibleCluster& incompatible_cluster(const EventFailureReason* msg); }; const ::flyteidl::admin::EventErrorAlreadyInTerminalState& EventFailureReason::HasBitSetters::already_in_terminal_state(const EventFailureReason* msg) { return *msg->reason_.already_in_terminal_state_; } +const ::flyteidl::admin::EventErrorIncompatibleCluster& +EventFailureReason::HasBitSetters::incompatible_cluster(const EventFailureReason* msg) { + return *msg->reason_.incompatible_cluster_; +} void EventFailureReason::set_allocated_already_in_terminal_state(::flyteidl::admin::EventErrorAlreadyInTerminalState* already_in_terminal_state) { ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); clear_reason(); @@ -632,8 +971,23 @@ void EventFailureReason::set_allocated_already_in_terminal_state(::flyteidl::adm } // @@protoc_insertion_point(field_set_allocated:flyteidl.admin.EventFailureReason.already_in_terminal_state) } +void EventFailureReason::set_allocated_incompatible_cluster(::flyteidl::admin::EventErrorIncompatibleCluster* incompatible_cluster) { + ::google::protobuf::Arena* message_arena = GetArenaNoVirtual(); + clear_reason(); + if (incompatible_cluster) { + ::google::protobuf::Arena* submessage_arena = nullptr; + if (message_arena != submessage_arena) { + incompatible_cluster = ::google::protobuf::internal::GetOwnedMessage( + message_arena, incompatible_cluster, submessage_arena); + } + set_has_incompatible_cluster(); + reason_.incompatible_cluster_ = incompatible_cluster; + } + // @@protoc_insertion_point(field_set_allocated:flyteidl.admin.EventFailureReason.incompatible_cluster) +} #if !defined(_MSC_VER) || _MSC_VER >= 1900 const int EventFailureReason::kAlreadyInTerminalStateFieldNumber; +const int EventFailureReason::kIncompatibleClusterFieldNumber; #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 EventFailureReason::EventFailureReason() @@ -651,6 +1005,10 @@ EventFailureReason::EventFailureReason(const EventFailureReason& from) mutable_already_in_terminal_state()->::flyteidl::admin::EventErrorAlreadyInTerminalState::MergeFrom(from.already_in_terminal_state()); break; } + case kIncompatibleCluster: { + mutable_incompatible_cluster()->::flyteidl::admin::EventErrorIncompatibleCluster::MergeFrom(from.incompatible_cluster()); + break; + } case REASON_NOT_SET: { break; } @@ -691,6 +1049,10 @@ void EventFailureReason::clear_reason() { delete reason_.already_in_terminal_state_; break; } + case kIncompatibleCluster: { + delete reason_.incompatible_cluster_; + break; + } case REASON_NOT_SET: { break; } @@ -735,6 +1097,19 @@ const char* EventFailureReason::_InternalParse(const char* begin, const char* en {parser_till_end, object}, ptr - size, ptr)); break; } + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + case 2: { + if (static_cast<::google::protobuf::uint8>(tag) != 18) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + parser_till_end = ::flyteidl::admin::EventErrorIncompatibleCluster::_InternalParse; + object = msg->mutable_incompatible_cluster(); + if (size > end - ptr) goto len_delim_till_end; + ptr += size; + GOOGLE_PROTOBUF_PARSER_ASSERT(ctx->ParseExactRange( + {parser_till_end, object}, ptr - size, ptr)); + break; + } default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { @@ -776,6 +1151,17 @@ bool EventFailureReason::MergePartialFromCodedStream( break; } + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + case 2: { + if (static_cast< ::google::protobuf::uint8>(tag) == (18 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( + input, mutable_incompatible_cluster())); + } else { + goto handle_unusual; + } + break; + } + default: { handle_unusual: if (tag == 0) { @@ -809,6 +1195,12 @@ void EventFailureReason::SerializeWithCachedSizes( 1, HasBitSetters::already_in_terminal_state(this), output); } + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + if (has_incompatible_cluster()) { + ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( + 2, HasBitSetters::incompatible_cluster(this), output); + } + if (_internal_metadata_.have_unknown_fields()) { ::google::protobuf::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); @@ -829,6 +1221,13 @@ ::google::protobuf::uint8* EventFailureReason::InternalSerializeWithCachedSizesT 1, HasBitSetters::already_in_terminal_state(this), target); } + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + if (has_incompatible_cluster()) { + target = ::google::protobuf::internal::WireFormatLite:: + InternalWriteMessageToArray( + 2, HasBitSetters::incompatible_cluster(this), target); + } + if (_internal_metadata_.have_unknown_fields()) { target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); @@ -858,6 +1257,13 @@ size_t EventFailureReason::ByteSizeLong() const { *reason_.already_in_terminal_state_); break; } + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + case kIncompatibleCluster: { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::MessageSize( + *reason_.incompatible_cluster_); + break; + } case REASON_NOT_SET: { break; } @@ -894,6 +1300,10 @@ void EventFailureReason::MergeFrom(const EventFailureReason& from) { mutable_already_in_terminal_state()->::flyteidl::admin::EventErrorAlreadyInTerminalState::MergeFrom(from.already_in_terminal_state()); break; } + case kIncompatibleCluster: { + mutable_incompatible_cluster()->::flyteidl::admin::EventErrorIncompatibleCluster::MergeFrom(from.incompatible_cluster()); + break; + } case REASON_NOT_SET: { break; } @@ -2680,6 +3090,9 @@ namespace protobuf { template<> PROTOBUF_NOINLINE ::flyteidl::admin::EventErrorAlreadyInTerminalState* Arena::CreateMaybeMessage< ::flyteidl::admin::EventErrorAlreadyInTerminalState >(Arena* arena) { return Arena::CreateInternal< ::flyteidl::admin::EventErrorAlreadyInTerminalState >(arena); } +template<> PROTOBUF_NOINLINE ::flyteidl::admin::EventErrorIncompatibleCluster* Arena::CreateMaybeMessage< ::flyteidl::admin::EventErrorIncompatibleCluster >(Arena* arena) { + return Arena::CreateInternal< ::flyteidl::admin::EventErrorIncompatibleCluster >(arena); +} template<> PROTOBUF_NOINLINE ::flyteidl::admin::EventFailureReason* Arena::CreateMaybeMessage< ::flyteidl::admin::EventFailureReason >(Arena* arena) { return Arena::CreateInternal< ::flyteidl::admin::EventFailureReason >(arena); } diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.h b/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.h index 17feca3e52..0301c4c77a 100644 --- a/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.h +++ b/flyteidl/gen/pb-cpp/flyteidl/admin/event.pb.h @@ -42,7 +42,7 @@ struct TableStruct_flyteidl_2fadmin_2fevent_2eproto { PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::google::protobuf::internal::AuxillaryParseTableField aux[] PROTOBUF_SECTION_VARIABLE(protodesc_cold); - static const ::google::protobuf::internal::ParseTable schema[8] + static const ::google::protobuf::internal::ParseTable schema[9] PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::google::protobuf::internal::FieldMetadata field_metadata[]; static const ::google::protobuf::internal::SerializationTable serialization_table[]; @@ -54,6 +54,9 @@ namespace admin { class EventErrorAlreadyInTerminalState; class EventErrorAlreadyInTerminalStateDefaultTypeInternal; extern EventErrorAlreadyInTerminalStateDefaultTypeInternal _EventErrorAlreadyInTerminalState_default_instance_; +class EventErrorIncompatibleCluster; +class EventErrorIncompatibleClusterDefaultTypeInternal; +extern EventErrorIncompatibleClusterDefaultTypeInternal _EventErrorIncompatibleCluster_default_instance_; class EventFailureReason; class EventFailureReasonDefaultTypeInternal; extern EventFailureReasonDefaultTypeInternal _EventFailureReason_default_instance_; @@ -80,6 +83,7 @@ extern WorkflowExecutionEventResponseDefaultTypeInternal _WorkflowExecutionEvent namespace google { namespace protobuf { template<> ::flyteidl::admin::EventErrorAlreadyInTerminalState* Arena::CreateMaybeMessage<::flyteidl::admin::EventErrorAlreadyInTerminalState>(Arena*); +template<> ::flyteidl::admin::EventErrorIncompatibleCluster* Arena::CreateMaybeMessage<::flyteidl::admin::EventErrorIncompatibleCluster>(Arena*); template<> ::flyteidl::admin::EventFailureReason* Arena::CreateMaybeMessage<::flyteidl::admin::EventFailureReason>(Arena*); template<> ::flyteidl::admin::NodeExecutionEventRequest* Arena::CreateMaybeMessage<::flyteidl::admin::NodeExecutionEventRequest>(Arena*); template<> ::flyteidl::admin::NodeExecutionEventResponse* Arena::CreateMaybeMessage<::flyteidl::admin::NodeExecutionEventResponse>(Arena*); @@ -214,6 +218,126 @@ class EventErrorAlreadyInTerminalState final : }; // ------------------------------------------------------------------- +class EventErrorIncompatibleCluster final : + public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:flyteidl.admin.EventErrorIncompatibleCluster) */ { + public: + EventErrorIncompatibleCluster(); + virtual ~EventErrorIncompatibleCluster(); + + EventErrorIncompatibleCluster(const EventErrorIncompatibleCluster& from); + + inline EventErrorIncompatibleCluster& operator=(const EventErrorIncompatibleCluster& from) { + CopyFrom(from); + return *this; + } + #if LANG_CXX11 + EventErrorIncompatibleCluster(EventErrorIncompatibleCluster&& from) noexcept + : EventErrorIncompatibleCluster() { + *this = ::std::move(from); + } + + inline EventErrorIncompatibleCluster& operator=(EventErrorIncompatibleCluster&& from) noexcept { + if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { + if (this != &from) InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } + #endif + static const ::google::protobuf::Descriptor* descriptor() { + return default_instance().GetDescriptor(); + } + static const EventErrorIncompatibleCluster& default_instance(); + + static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY + static inline const EventErrorIncompatibleCluster* internal_default_instance() { + return reinterpret_cast( + &_EventErrorIncompatibleCluster_default_instance_); + } + static constexpr int kIndexInFileMessages = + 1; + + void Swap(EventErrorIncompatibleCluster* other); + friend void swap(EventErrorIncompatibleCluster& a, EventErrorIncompatibleCluster& b) { + a.Swap(&b); + } + + // implements Message ---------------------------------------------- + + inline EventErrorIncompatibleCluster* New() const final { + return CreateMaybeMessage(nullptr); + } + + EventErrorIncompatibleCluster* New(::google::protobuf::Arena* arena) const final { + return CreateMaybeMessage(arena); + } + void CopyFrom(const ::google::protobuf::Message& from) final; + void MergeFrom(const ::google::protobuf::Message& from) final; + void CopyFrom(const EventErrorIncompatibleCluster& from); + void MergeFrom(const EventErrorIncompatibleCluster& from); + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; + + size_t ByteSizeLong() const final; + #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + static const char* _InternalParse(const char* begin, const char* end, void* object, ::google::protobuf::internal::ParseContext* ctx); + ::google::protobuf::internal::ParseFunc _ParseFunc() const final { return _InternalParse; } + #else + bool MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) final; + #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + void SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const final; + ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const final; + int GetCachedSize() const final { return _cached_size_.Get(); } + + private: + void SharedCtor(); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(EventErrorIncompatibleCluster* other); + private: + inline ::google::protobuf::Arena* GetArenaNoVirtual() const { + return nullptr; + } + inline void* MaybeArenaPtr() const { + return nullptr; + } + public: + + ::google::protobuf::Metadata GetMetadata() const final; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + // string cluster = 1; + void clear_cluster(); + static const int kClusterFieldNumber = 1; + const ::std::string& cluster() const; + void set_cluster(const ::std::string& value); + #if LANG_CXX11 + void set_cluster(::std::string&& value); + #endif + void set_cluster(const char* value); + void set_cluster(const char* value, size_t size); + ::std::string* mutable_cluster(); + ::std::string* release_cluster(); + void set_allocated_cluster(::std::string* cluster); + + // @@protoc_insertion_point(class_scope:flyteidl.admin.EventErrorIncompatibleCluster) + private: + class HasBitSetters; + + ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; + ::google::protobuf::internal::ArenaStringPtr cluster_; + mutable ::google::protobuf::internal::CachedSize _cached_size_; + friend struct ::TableStruct_flyteidl_2fadmin_2fevent_2eproto; +}; +// ------------------------------------------------------------------- + class EventFailureReason final : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:flyteidl.admin.EventFailureReason) */ { public: @@ -248,6 +372,7 @@ class EventFailureReason final : enum ReasonCase { kAlreadyInTerminalState = 1, + kIncompatibleCluster = 2, REASON_NOT_SET = 0, }; @@ -257,7 +382,7 @@ class EventFailureReason final : &_EventFailureReason_default_instance_); } static constexpr int kIndexInFileMessages = - 1; + 2; void Swap(EventFailureReason* other); friend void swap(EventFailureReason& a, EventFailureReason& b) { @@ -323,12 +448,22 @@ class EventFailureReason final : ::flyteidl::admin::EventErrorAlreadyInTerminalState* mutable_already_in_terminal_state(); void set_allocated_already_in_terminal_state(::flyteidl::admin::EventErrorAlreadyInTerminalState* already_in_terminal_state); + // .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + bool has_incompatible_cluster() const; + void clear_incompatible_cluster(); + static const int kIncompatibleClusterFieldNumber = 2; + const ::flyteidl::admin::EventErrorIncompatibleCluster& incompatible_cluster() const; + ::flyteidl::admin::EventErrorIncompatibleCluster* release_incompatible_cluster(); + ::flyteidl::admin::EventErrorIncompatibleCluster* mutable_incompatible_cluster(); + void set_allocated_incompatible_cluster(::flyteidl::admin::EventErrorIncompatibleCluster* incompatible_cluster); + void clear_reason(); ReasonCase reason_case() const; // @@protoc_insertion_point(class_scope:flyteidl.admin.EventFailureReason) private: class HasBitSetters; void set_has_already_in_terminal_state(); + void set_has_incompatible_cluster(); inline bool has_reason() const; inline void clear_has_reason(); @@ -337,6 +472,7 @@ class EventFailureReason final : union ReasonUnion { ReasonUnion() {} ::flyteidl::admin::EventErrorAlreadyInTerminalState* already_in_terminal_state_; + ::flyteidl::admin::EventErrorIncompatibleCluster* incompatible_cluster_; } reason_; mutable ::google::protobuf::internal::CachedSize _cached_size_; ::google::protobuf::uint32 _oneof_case_[1]; @@ -383,7 +519,7 @@ class WorkflowExecutionEventRequest final : &_WorkflowExecutionEventRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 2; + 3; void Swap(WorkflowExecutionEventRequest* other); friend void swap(WorkflowExecutionEventRequest& a, WorkflowExecutionEventRequest& b) { @@ -513,7 +649,7 @@ class WorkflowExecutionEventResponse final : &_WorkflowExecutionEventResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 3; + 4; void Swap(WorkflowExecutionEventResponse* other); friend void swap(WorkflowExecutionEventResponse& a, WorkflowExecutionEventResponse& b) { @@ -618,7 +754,7 @@ class NodeExecutionEventRequest final : &_NodeExecutionEventRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 4; + 5; void Swap(NodeExecutionEventRequest* other); friend void swap(NodeExecutionEventRequest& a, NodeExecutionEventRequest& b) { @@ -748,7 +884,7 @@ class NodeExecutionEventResponse final : &_NodeExecutionEventResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 5; + 6; void Swap(NodeExecutionEventResponse* other); friend void swap(NodeExecutionEventResponse& a, NodeExecutionEventResponse& b) { @@ -853,7 +989,7 @@ class TaskExecutionEventRequest final : &_TaskExecutionEventRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 6; + 7; void Swap(TaskExecutionEventRequest* other); friend void swap(TaskExecutionEventRequest& a, TaskExecutionEventRequest& b) { @@ -983,7 +1119,7 @@ class TaskExecutionEventResponse final : &_TaskExecutionEventResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 7; + 8; void Swap(TaskExecutionEventResponse* other); friend void swap(TaskExecutionEventResponse& a, TaskExecutionEventResponse& b) { @@ -1114,6 +1250,63 @@ inline void EventErrorAlreadyInTerminalState::set_allocated_current_phase(::std: // ------------------------------------------------------------------- +// EventErrorIncompatibleCluster + +// string cluster = 1; +inline void EventErrorIncompatibleCluster::clear_cluster() { + cluster_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline const ::std::string& EventErrorIncompatibleCluster::cluster() const { + // @@protoc_insertion_point(field_get:flyteidl.admin.EventErrorIncompatibleCluster.cluster) + return cluster_.GetNoArena(); +} +inline void EventErrorIncompatibleCluster::set_cluster(const ::std::string& value) { + + cluster_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); + // @@protoc_insertion_point(field_set:flyteidl.admin.EventErrorIncompatibleCluster.cluster) +} +#if LANG_CXX11 +inline void EventErrorIncompatibleCluster::set_cluster(::std::string&& value) { + + cluster_.SetNoArena( + &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); + // @@protoc_insertion_point(field_set_rvalue:flyteidl.admin.EventErrorIncompatibleCluster.cluster) +} +#endif +inline void EventErrorIncompatibleCluster::set_cluster(const char* value) { + GOOGLE_DCHECK(value != nullptr); + + cluster_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); + // @@protoc_insertion_point(field_set_char:flyteidl.admin.EventErrorIncompatibleCluster.cluster) +} +inline void EventErrorIncompatibleCluster::set_cluster(const char* value, size_t size) { + + cluster_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), + ::std::string(reinterpret_cast(value), size)); + // @@protoc_insertion_point(field_set_pointer:flyteidl.admin.EventErrorIncompatibleCluster.cluster) +} +inline ::std::string* EventErrorIncompatibleCluster::mutable_cluster() { + + // @@protoc_insertion_point(field_mutable:flyteidl.admin.EventErrorIncompatibleCluster.cluster) + return cluster_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline ::std::string* EventErrorIncompatibleCluster::release_cluster() { + // @@protoc_insertion_point(field_release:flyteidl.admin.EventErrorIncompatibleCluster.cluster) + + return cluster_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline void EventErrorIncompatibleCluster::set_allocated_cluster(::std::string* cluster) { + if (cluster != nullptr) { + + } else { + + } + cluster_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), cluster); + // @@protoc_insertion_point(field_set_allocated:flyteidl.admin.EventErrorIncompatibleCluster.cluster) +} + +// ------------------------------------------------------------------- + // EventFailureReason // .flyteidl.admin.EventErrorAlreadyInTerminalState already_in_terminal_state = 1; @@ -1157,6 +1350,47 @@ inline ::flyteidl::admin::EventErrorAlreadyInTerminalState* EventFailureReason:: return reason_.already_in_terminal_state_; } +// .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; +inline bool EventFailureReason::has_incompatible_cluster() const { + return reason_case() == kIncompatibleCluster; +} +inline void EventFailureReason::set_has_incompatible_cluster() { + _oneof_case_[0] = kIncompatibleCluster; +} +inline void EventFailureReason::clear_incompatible_cluster() { + if (has_incompatible_cluster()) { + delete reason_.incompatible_cluster_; + clear_has_reason(); + } +} +inline ::flyteidl::admin::EventErrorIncompatibleCluster* EventFailureReason::release_incompatible_cluster() { + // @@protoc_insertion_point(field_release:flyteidl.admin.EventFailureReason.incompatible_cluster) + if (has_incompatible_cluster()) { + clear_has_reason(); + ::flyteidl::admin::EventErrorIncompatibleCluster* temp = reason_.incompatible_cluster_; + reason_.incompatible_cluster_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline const ::flyteidl::admin::EventErrorIncompatibleCluster& EventFailureReason::incompatible_cluster() const { + // @@protoc_insertion_point(field_get:flyteidl.admin.EventFailureReason.incompatible_cluster) + return has_incompatible_cluster() + ? *reason_.incompatible_cluster_ + : *reinterpret_cast< ::flyteidl::admin::EventErrorIncompatibleCluster*>(&::flyteidl::admin::_EventErrorIncompatibleCluster_default_instance_); +} +inline ::flyteidl::admin::EventErrorIncompatibleCluster* EventFailureReason::mutable_incompatible_cluster() { + if (!has_incompatible_cluster()) { + clear_reason(); + set_has_incompatible_cluster(); + reason_.incompatible_cluster_ = CreateMaybeMessage< ::flyteidl::admin::EventErrorIncompatibleCluster >( + GetArenaNoVirtual()); + } + // @@protoc_insertion_point(field_mutable:flyteidl.admin.EventFailureReason.incompatible_cluster) + return reason_.incompatible_cluster_; +} + inline bool EventFailureReason::has_reason() const { return reason_case() != REASON_NOT_SET; } @@ -1501,6 +1735,8 @@ inline void TaskExecutionEventRequest::set_allocated_event(::flyteidl::event::Ta // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) diff --git a/flyteidl/gen/pb-go/flyteidl/admin/event.pb.go b/flyteidl/gen/pb-go/flyteidl/admin/event.pb.go index e97d30a7bc..4e2edecb9f 100644 --- a/flyteidl/gen/pb-go/flyteidl/admin/event.pb.go +++ b/flyteidl/gen/pb-go/flyteidl/admin/event.pb.go @@ -64,12 +64,56 @@ func (m *EventErrorAlreadyInTerminalState) GetCurrentPhase() string { return "" } +// Indicates an event was rejected because it came from a different cluster than +// is on record as running the execution. +type EventErrorIncompatibleCluster struct { + // The cluster which has been recorded as processing the execution. + // +required + Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *EventErrorIncompatibleCluster) Reset() { *m = EventErrorIncompatibleCluster{} } +func (m *EventErrorIncompatibleCluster) String() string { return proto.CompactTextString(m) } +func (*EventErrorIncompatibleCluster) ProtoMessage() {} +func (*EventErrorIncompatibleCluster) Descriptor() ([]byte, []int) { + return fileDescriptor_4581752dea61f248, []int{1} +} + +func (m *EventErrorIncompatibleCluster) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_EventErrorIncompatibleCluster.Unmarshal(m, b) +} +func (m *EventErrorIncompatibleCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_EventErrorIncompatibleCluster.Marshal(b, m, deterministic) +} +func (m *EventErrorIncompatibleCluster) XXX_Merge(src proto.Message) { + xxx_messageInfo_EventErrorIncompatibleCluster.Merge(m, src) +} +func (m *EventErrorIncompatibleCluster) XXX_Size() int { + return xxx_messageInfo_EventErrorIncompatibleCluster.Size(m) +} +func (m *EventErrorIncompatibleCluster) XXX_DiscardUnknown() { + xxx_messageInfo_EventErrorIncompatibleCluster.DiscardUnknown(m) +} + +var xxx_messageInfo_EventErrorIncompatibleCluster proto.InternalMessageInfo + +func (m *EventErrorIncompatibleCluster) GetCluster() string { + if m != nil { + return m.Cluster + } + return "" +} + // Indicates why a sent event was not used to update execution. type EventFailureReason struct { // +required // // Types that are valid to be assigned to Reason: // *EventFailureReason_AlreadyInTerminalState + // *EventFailureReason_IncompatibleCluster Reason isEventFailureReason_Reason `protobuf_oneof:"reason"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -80,7 +124,7 @@ func (m *EventFailureReason) Reset() { *m = EventFailureReason{} } func (m *EventFailureReason) String() string { return proto.CompactTextString(m) } func (*EventFailureReason) ProtoMessage() {} func (*EventFailureReason) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{1} + return fileDescriptor_4581752dea61f248, []int{2} } func (m *EventFailureReason) XXX_Unmarshal(b []byte) error { @@ -109,8 +153,14 @@ type EventFailureReason_AlreadyInTerminalState struct { AlreadyInTerminalState *EventErrorAlreadyInTerminalState `protobuf:"bytes,1,opt,name=already_in_terminal_state,json=alreadyInTerminalState,proto3,oneof"` } +type EventFailureReason_IncompatibleCluster struct { + IncompatibleCluster *EventErrorIncompatibleCluster `protobuf:"bytes,2,opt,name=incompatible_cluster,json=incompatibleCluster,proto3,oneof"` +} + func (*EventFailureReason_AlreadyInTerminalState) isEventFailureReason_Reason() {} +func (*EventFailureReason_IncompatibleCluster) isEventFailureReason_Reason() {} + func (m *EventFailureReason) GetReason() isEventFailureReason_Reason { if m != nil { return m.Reason @@ -125,10 +175,18 @@ func (m *EventFailureReason) GetAlreadyInTerminalState() *EventErrorAlreadyInTer return nil } +func (m *EventFailureReason) GetIncompatibleCluster() *EventErrorIncompatibleCluster { + if x, ok := m.GetReason().(*EventFailureReason_IncompatibleCluster); ok { + return x.IncompatibleCluster + } + return nil +} + // XXX_OneofWrappers is for the internal use of the proto package. func (*EventFailureReason) XXX_OneofWrappers() []interface{} { return []interface{}{ (*EventFailureReason_AlreadyInTerminalState)(nil), + (*EventFailureReason_IncompatibleCluster)(nil), } } @@ -147,7 +205,7 @@ func (m *WorkflowExecutionEventRequest) Reset() { *m = WorkflowExecution func (m *WorkflowExecutionEventRequest) String() string { return proto.CompactTextString(m) } func (*WorkflowExecutionEventRequest) ProtoMessage() {} func (*WorkflowExecutionEventRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{2} + return fileDescriptor_4581752dea61f248, []int{3} } func (m *WorkflowExecutionEventRequest) XXX_Unmarshal(b []byte) error { @@ -192,7 +250,7 @@ func (m *WorkflowExecutionEventResponse) Reset() { *m = WorkflowExecutio func (m *WorkflowExecutionEventResponse) String() string { return proto.CompactTextString(m) } func (*WorkflowExecutionEventResponse) ProtoMessage() {} func (*WorkflowExecutionEventResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{3} + return fileDescriptor_4581752dea61f248, []int{4} } func (m *WorkflowExecutionEventResponse) XXX_Unmarshal(b []byte) error { @@ -228,7 +286,7 @@ func (m *NodeExecutionEventRequest) Reset() { *m = NodeExecutionEventReq func (m *NodeExecutionEventRequest) String() string { return proto.CompactTextString(m) } func (*NodeExecutionEventRequest) ProtoMessage() {} func (*NodeExecutionEventRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{4} + return fileDescriptor_4581752dea61f248, []int{5} } func (m *NodeExecutionEventRequest) XXX_Unmarshal(b []byte) error { @@ -273,7 +331,7 @@ func (m *NodeExecutionEventResponse) Reset() { *m = NodeExecutionEventRe func (m *NodeExecutionEventResponse) String() string { return proto.CompactTextString(m) } func (*NodeExecutionEventResponse) ProtoMessage() {} func (*NodeExecutionEventResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{5} + return fileDescriptor_4581752dea61f248, []int{6} } func (m *NodeExecutionEventResponse) XXX_Unmarshal(b []byte) error { @@ -309,7 +367,7 @@ func (m *TaskExecutionEventRequest) Reset() { *m = TaskExecutionEventReq func (m *TaskExecutionEventRequest) String() string { return proto.CompactTextString(m) } func (*TaskExecutionEventRequest) ProtoMessage() {} func (*TaskExecutionEventRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{6} + return fileDescriptor_4581752dea61f248, []int{7} } func (m *TaskExecutionEventRequest) XXX_Unmarshal(b []byte) error { @@ -354,7 +412,7 @@ func (m *TaskExecutionEventResponse) Reset() { *m = TaskExecutionEventRe func (m *TaskExecutionEventResponse) String() string { return proto.CompactTextString(m) } func (*TaskExecutionEventResponse) ProtoMessage() {} func (*TaskExecutionEventResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_4581752dea61f248, []int{7} + return fileDescriptor_4581752dea61f248, []int{8} } func (m *TaskExecutionEventResponse) XXX_Unmarshal(b []byte) error { @@ -377,6 +435,7 @@ var xxx_messageInfo_TaskExecutionEventResponse proto.InternalMessageInfo func init() { proto.RegisterType((*EventErrorAlreadyInTerminalState)(nil), "flyteidl.admin.EventErrorAlreadyInTerminalState") + proto.RegisterType((*EventErrorIncompatibleCluster)(nil), "flyteidl.admin.EventErrorIncompatibleCluster") proto.RegisterType((*EventFailureReason)(nil), "flyteidl.admin.EventFailureReason") proto.RegisterType((*WorkflowExecutionEventRequest)(nil), "flyteidl.admin.WorkflowExecutionEventRequest") proto.RegisterType((*WorkflowExecutionEventResponse)(nil), "flyteidl.admin.WorkflowExecutionEventResponse") @@ -389,27 +448,31 @@ func init() { func init() { proto.RegisterFile("flyteidl/admin/event.proto", fileDescriptor_4581752dea61f248) } var fileDescriptor_4581752dea61f248 = []byte{ - // 349 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x93, 0x4f, 0x4b, 0xf3, 0x40, - 0x10, 0x87, 0xdf, 0xbe, 0x60, 0xb1, 0xe3, 0x9f, 0x43, 0x0e, 0xd2, 0x16, 0x2b, 0x25, 0x82, 0x78, - 0x31, 0x11, 0x45, 0xf4, 0xe0, 0xc5, 0x42, 0xd5, 0x5e, 0x44, 0x62, 0x41, 0xf0, 0x12, 0xb6, 0xcd, - 0x34, 0x5d, 0x9a, 0xec, 0xc6, 0xd9, 0x8d, 0x5a, 0xf0, 0x2b, 0xf8, 0x9d, 0xa5, 0x9b, 0x68, 0x8c, - 0xa4, 0x08, 0x82, 0xb7, 0x64, 0x66, 0xf2, 0xfc, 0x9e, 0x2c, 0xb3, 0xd0, 0x9e, 0x44, 0x73, 0x8d, - 0x3c, 0x88, 0x5c, 0x16, 0xc4, 0x5c, 0xb8, 0xf8, 0x84, 0x42, 0x3b, 0x09, 0x49, 0x2d, 0xad, 0xcd, - 0x8f, 0x9e, 0x63, 0x7a, 0xed, 0x62, 0xd6, 0x4c, 0x7d, 0x9d, 0xb5, 0xaf, 0xa0, 0xdb, 0x5f, 0xbc, - 0xf6, 0x89, 0x24, 0x5d, 0x44, 0x84, 0x2c, 0x98, 0x0f, 0xc4, 0x10, 0x29, 0xe6, 0x82, 0x45, 0x77, - 0x9a, 0x69, 0xb4, 0x76, 0x61, 0x63, 0x9c, 0x12, 0xa1, 0xd0, 0x7e, 0x32, 0x65, 0x0a, 0x9b, 0xb5, - 0x6e, 0x6d, 0xbf, 0xe1, 0xad, 0xe7, 0xc5, 0xdb, 0x45, 0xcd, 0x7e, 0xab, 0x81, 0x65, 0x48, 0x97, - 0x8c, 0x47, 0x29, 0xa1, 0x87, 0x4c, 0x49, 0x61, 0xc5, 0xd0, 0x62, 0x19, 0xd5, 0xe7, 0xc2, 0xd7, - 0x39, 0xd7, 0x57, 0x0b, 0xb0, 0xe1, 0xac, 0x1d, 0x1d, 0x3a, 0x65, 0x5f, 0xe7, 0x27, 0xa1, 0xeb, - 0x7f, 0xde, 0x16, 0xab, 0xec, 0xf4, 0x56, 0xa1, 0x4e, 0x26, 0xd8, 0x7e, 0x85, 0xce, 0xbd, 0xa4, - 0xd9, 0x24, 0x92, 0xcf, 0xfd, 0x17, 0x1c, 0xa7, 0x9a, 0x4b, 0x61, 0xc0, 0x1e, 0x3e, 0xa6, 0xa8, - 0xb4, 0xd5, 0x01, 0xa0, 0xec, 0xd1, 0xe7, 0x41, 0xfe, 0x4b, 0x8d, 0xbc, 0x32, 0x08, 0xac, 0x73, - 0x58, 0x31, 0xe7, 0xd4, 0xfc, 0x6f, 0x24, 0xf7, 0x0a, 0xc9, 0xec, 0xf8, 0x96, 0xc0, 0xb3, 0x8f, - 0xec, 0x2e, 0xec, 0x2c, 0x4b, 0x57, 0x89, 0x14, 0x0a, 0x6d, 0x0d, 0xad, 0x1b, 0x19, 0xe0, 0xaf, - 0xdc, 0xce, 0xca, 0x6e, 0xf6, 0x77, 0xb7, 0x0a, 0x70, 0xee, 0xb5, 0x0d, 0xed, 0xaa, 0xd4, 0xc2, - 0x69, 0xc8, 0xd4, 0xec, 0x4f, 0x9c, 0x2a, 0xc0, 0x85, 0x53, 0x55, 0x6a, 0xe6, 0xd4, 0x3b, 0x7d, - 0x38, 0x09, 0xb9, 0x9e, 0xa6, 0x23, 0x67, 0x2c, 0x63, 0xd7, 0x40, 0x25, 0x85, 0xee, 0xe7, 0x4a, - 0x87, 0x28, 0xdc, 0x64, 0x74, 0x10, 0x4a, 0xb7, 0x7c, 0x23, 0x46, 0x75, 0xb3, 0xe0, 0xc7, 0xef, - 0x01, 0x00, 0x00, 0xff, 0xff, 0x7b, 0xb0, 0xc6, 0xd1, 0x2a, 0x03, 0x00, 0x00, + // 404 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x93, 0x5f, 0x6b, 0xdb, 0x30, + 0x14, 0xc5, 0x93, 0xc1, 0xb2, 0xe5, 0xee, 0xcf, 0x83, 0x37, 0x46, 0x12, 0x96, 0x11, 0x3c, 0x18, + 0x7b, 0x89, 0x3d, 0x36, 0x46, 0x5b, 0xe8, 0x4b, 0x53, 0xd2, 0x26, 0x2f, 0xa5, 0xb8, 0x81, 0x42, + 0x5f, 0x8c, 0x6c, 0xdf, 0x38, 0x22, 0xb2, 0xe4, 0x4a, 0x72, 0xdb, 0x40, 0xbf, 0x74, 0xbf, 0x41, + 0x89, 0xec, 0xd4, 0x49, 0xeb, 0x50, 0x28, 0xf4, 0xcd, 0xba, 0xba, 0xf7, 0x9c, 0xdf, 0xb1, 0xb8, + 0xd0, 0x99, 0xb2, 0x85, 0x46, 0x1a, 0x31, 0x97, 0x44, 0x09, 0xe5, 0x2e, 0x5e, 0x21, 0xd7, 0x4e, + 0x2a, 0x85, 0x16, 0xd6, 0xe7, 0xd5, 0x9d, 0x63, 0xee, 0x3a, 0x65, 0xaf, 0xe9, 0x5a, 0xef, 0xb5, + 0x8f, 0xa1, 0x37, 0x5c, 0x1e, 0x87, 0x52, 0x0a, 0x79, 0xc0, 0x24, 0x92, 0x68, 0x31, 0xe6, 0x13, + 0x94, 0x09, 0xe5, 0x84, 0x9d, 0x69, 0xa2, 0xd1, 0xfa, 0x09, 0x9f, 0xc2, 0x4c, 0x4a, 0xe4, 0xda, + 0x4f, 0x67, 0x44, 0x61, 0xab, 0xde, 0xab, 0xff, 0x6e, 0x7a, 0x1f, 0x8b, 0xe2, 0xe9, 0xb2, 0x66, + 0xef, 0x41, 0xb7, 0x14, 0x1a, 0xf3, 0x50, 0x24, 0x29, 0xd1, 0x34, 0x60, 0x78, 0xc8, 0x32, 0xa5, + 0x51, 0x5a, 0x2d, 0x78, 0x17, 0xe6, 0x9f, 0xc5, 0xfc, 0xea, 0x68, 0xdf, 0xd5, 0xc1, 0x32, 0xb3, + 0x47, 0x84, 0xb2, 0x4c, 0xa2, 0x87, 0x44, 0x09, 0x6e, 0x25, 0xd0, 0x26, 0x39, 0x90, 0x4f, 0xb9, + 0xaf, 0x0b, 0x24, 0x5f, 0x2d, 0x99, 0x8c, 0xc4, 0x87, 0xbf, 0x7f, 0x9c, 0xcd, 0xa8, 0xce, 0x73, + 0x59, 0x46, 0x35, 0xef, 0x1b, 0xa9, 0x4e, 0x19, 0xc0, 0x57, 0xba, 0x86, 0xed, 0xaf, 0x60, 0xdf, + 0x18, 0xa7, 0xfe, 0x76, 0xa7, 0x8a, 0xb0, 0xa3, 0x9a, 0xf7, 0x85, 0x3e, 0x2d, 0x0f, 0xde, 0x43, + 0x43, 0x9a, 0x70, 0xf6, 0x2d, 0x74, 0xcf, 0x85, 0x9c, 0x4f, 0x99, 0xb8, 0x1e, 0xde, 0x60, 0x98, + 0x69, 0x2a, 0xb8, 0x91, 0xf4, 0xf0, 0x32, 0x43, 0xa5, 0xad, 0x2e, 0x80, 0xcc, 0x3f, 0x7d, 0x1a, + 0x15, 0x7f, 0xac, 0x59, 0x54, 0xc6, 0x91, 0xb5, 0x0f, 0x6f, 0xcd, 0x33, 0x16, 0x78, 0xbf, 0x4a, + 0xbc, 0xfc, 0x75, 0xb7, 0x88, 0xe7, 0x43, 0x76, 0x0f, 0x7e, 0x6c, 0x73, 0x57, 0xa9, 0xe0, 0x0a, + 0x6d, 0x0d, 0xed, 0x13, 0x11, 0xe1, 0x8b, 0xd8, 0x76, 0x37, 0xd9, 0xec, 0xc7, 0x6c, 0x15, 0xc2, + 0x05, 0xd7, 0x77, 0xe8, 0x54, 0xb9, 0x96, 0x4c, 0x13, 0xa2, 0xe6, 0xaf, 0xc2, 0x54, 0x21, 0x5c, + 0x32, 0x55, 0xb9, 0xe6, 0x4c, 0x83, 0x9d, 0x8b, 0xff, 0x31, 0xd5, 0xb3, 0x2c, 0x70, 0x42, 0x91, + 0xb8, 0x46, 0x54, 0xc8, 0xd8, 0x7d, 0xd8, 0xb8, 0x18, 0xb9, 0x9b, 0x06, 0xfd, 0x58, 0xb8, 0x9b, + 0x0b, 0x1b, 0x34, 0xcc, 0xfe, 0xfd, 0xbb, 0x0f, 0x00, 0x00, 0xff, 0xff, 0x10, 0x23, 0xbf, 0x80, + 0xc9, 0x03, 0x00, 0x00, } diff --git a/flyteidl/gen/pb-go/flyteidl/admin/event.pb.validate.go b/flyteidl/gen/pb-go/flyteidl/admin/event.pb.validate.go index bfa0a49b7c..04fd96c15d 100644 --- a/flyteidl/gen/pb-go/flyteidl/admin/event.pb.validate.go +++ b/flyteidl/gen/pb-go/flyteidl/admin/event.pb.validate.go @@ -106,6 +106,76 @@ var _ interface { ErrorName() string } = EventErrorAlreadyInTerminalStateValidationError{} +// Validate checks the field values on EventErrorIncompatibleCluster with the +// rules defined in the proto definition for this message. If any rules are +// violated, an error is returned. +func (m *EventErrorIncompatibleCluster) Validate() error { + if m == nil { + return nil + } + + // no validation rules for Cluster + + return nil +} + +// EventErrorIncompatibleClusterValidationError is the validation error +// returned by EventErrorIncompatibleCluster.Validate if the designated +// constraints aren't met. +type EventErrorIncompatibleClusterValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e EventErrorIncompatibleClusterValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e EventErrorIncompatibleClusterValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e EventErrorIncompatibleClusterValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e EventErrorIncompatibleClusterValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e EventErrorIncompatibleClusterValidationError) ErrorName() string { + return "EventErrorIncompatibleClusterValidationError" +} + +// Error satisfies the builtin error interface +func (e EventErrorIncompatibleClusterValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sEventErrorIncompatibleCluster.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = EventErrorIncompatibleClusterValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = EventErrorIncompatibleClusterValidationError{} + // Validate checks the field values on EventFailureReason with the rules // defined in the proto definition for this message. If any rules are // violated, an error is returned. @@ -128,6 +198,18 @@ func (m *EventFailureReason) Validate() error { } } + case *EventFailureReason_IncompatibleCluster: + + if v, ok := interface{}(m.GetIncompatibleCluster()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return EventFailureReasonValidationError{ + field: "IncompatibleCluster", + reason: "embedded message failed validation", + cause: err, + } + } + } + } return nil diff --git a/flyteidl/gen/pb-java/flyteidl/admin/Event.java b/flyteidl/gen/pb-java/flyteidl/admin/Event.java index 0e4505897b..2cf63d6c83 100644 --- a/flyteidl/gen/pb-java/flyteidl/admin/Event.java +++ b/flyteidl/gen/pb-java/flyteidl/admin/Event.java @@ -611,6 +611,610 @@ public flyteidl.admin.Event.EventErrorAlreadyInTerminalState getDefaultInstanceF } + public interface EventErrorIncompatibleClusterOrBuilder extends + // @@protoc_insertion_point(interface_extends:flyteidl.admin.EventErrorIncompatibleCluster) + com.google.protobuf.MessageOrBuilder { + + /** + * 
+     * The cluster which has been recorded as processing the execution.
+     * +required
+     *
+ * + * string cluster = 1; + */ + java.lang.String getCluster(); + /** + * 
+     * The cluster which has been recorded as processing the execution.
+     * +required
+     *
+ * + * string cluster = 1; + */ + com.google.protobuf.ByteString + getClusterBytes(); + } + /** + * 
+   * Indicates an event was rejected because it came from a different cluster than 
+   * is on record as running the execution.
+   *
+ * + * Protobuf type {@code flyteidl.admin.EventErrorIncompatibleCluster} + */ + public static final class EventErrorIncompatibleCluster extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:flyteidl.admin.EventErrorIncompatibleCluster) + EventErrorIncompatibleClusterOrBuilder { + private static final long serialVersionUID = 0L; + // Use EventErrorIncompatibleCluster.newBuilder() to construct. + private EventErrorIncompatibleCluster(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private EventErrorIncompatibleCluster() { + cluster_ = ""; + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private EventErrorIncompatibleCluster( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + java.lang.String s = input.readStringRequireUtf8(); + + cluster_ = s; + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return flyteidl.admin.Event.internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return flyteidl.admin.Event.internal_static_flyteidl_admin_EventErrorIncompatibleCluster_fieldAccessorTable + .ensureFieldAccessorsInitialized( + flyteidl.admin.Event.EventErrorIncompatibleCluster.class, flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder.class); + } + + public static final int CLUSTER_FIELD_NUMBER = 1; + private volatile java.lang.Object cluster_; + /** + * 
+     * The cluster which has been recorded as processing the execution.
+     * +required
+     *
+ * + * string cluster = 1; + */ + public java.lang.String getCluster() { + java.lang.Object ref = cluster_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + cluster_ = s; + return s; + } + } + /** + * 
+     * The cluster which has been recorded as processing the execution.
+     * +required
+     *
+ * + * string cluster = 1; + */ + public com.google.protobuf.ByteString + getClusterBytes() { + java.lang.Object ref = cluster_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + cluster_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!getClusterBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, cluster_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!getClusterBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, cluster_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof flyteidl.admin.Event.EventErrorIncompatibleCluster)) { + return super.equals(obj); + } + flyteidl.admin.Event.EventErrorIncompatibleCluster other = (flyteidl.admin.Event.EventErrorIncompatibleCluster) obj; + + if (!getCluster() + .equals(other.getCluster())) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + CLUSTER_FIELD_NUMBER; + hash = (53 * hash) + getCluster().hashCode(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static flyteidl.admin.Event.EventErrorIncompatibleCluster parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(flyteidl.admin.Event.EventErrorIncompatibleCluster prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * 
+     * Indicates an event was rejected because it came from a different cluster than 
+     * is on record as running the execution.
+     *
+ * + * Protobuf type {@code flyteidl.admin.EventErrorIncompatibleCluster} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:flyteidl.admin.EventErrorIncompatibleCluster) + flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return flyteidl.admin.Event.internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return flyteidl.admin.Event.internal_static_flyteidl_admin_EventErrorIncompatibleCluster_fieldAccessorTable + .ensureFieldAccessorsInitialized( + flyteidl.admin.Event.EventErrorIncompatibleCluster.class, flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder.class); + } + + // Construct using flyteidl.admin.Event.EventErrorIncompatibleCluster.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + cluster_ = ""; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return flyteidl.admin.Event.internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor; + } + + @java.lang.Override + public flyteidl.admin.Event.EventErrorIncompatibleCluster getDefaultInstanceForType() { + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + + @java.lang.Override + public flyteidl.admin.Event.EventErrorIncompatibleCluster build() { + flyteidl.admin.Event.EventErrorIncompatibleCluster result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public flyteidl.admin.Event.EventErrorIncompatibleCluster buildPartial() { + flyteidl.admin.Event.EventErrorIncompatibleCluster result = new flyteidl.admin.Event.EventErrorIncompatibleCluster(this); + result.cluster_ = cluster_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof flyteidl.admin.Event.EventErrorIncompatibleCluster) { + return mergeFrom((flyteidl.admin.Event.EventErrorIncompatibleCluster)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(flyteidl.admin.Event.EventErrorIncompatibleCluster other) { + if (other == flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance()) return this; + if (!other.getCluster().isEmpty()) { + cluster_ = other.cluster_; + onChanged(); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + flyteidl.admin.Event.EventErrorIncompatibleCluster parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (flyteidl.admin.Event.EventErrorIncompatibleCluster) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private java.lang.Object cluster_ = ""; + /** + * 
+       * The cluster which has been recorded as processing the execution.
+       * +required
+       *
+ * + * string cluster = 1; + */ + public java.lang.String getCluster() { + java.lang.Object ref = cluster_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + cluster_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * 
+       * The cluster which has been recorded as processing the execution.
+       * +required
+       *
+ * + * string cluster = 1; + */ + public com.google.protobuf.ByteString + getClusterBytes() { + java.lang.Object ref = cluster_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + cluster_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * 
+       * The cluster which has been recorded as processing the execution.
+       * +required
+       *
+ * + * string cluster = 1; + */ + public Builder setCluster( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + cluster_ = value; + onChanged(); + return this; + } + /** + * 
+       * The cluster which has been recorded as processing the execution.
+       * +required
+       *
+ * + * string cluster = 1; + */ + public Builder clearCluster() { + + cluster_ = getDefaultInstance().getCluster(); + onChanged(); + return this; + } + /** + * 
+       * The cluster which has been recorded as processing the execution.
+       * +required
+       *
+ * + * string cluster = 1; + */ + public Builder setClusterBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + cluster_ = value; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:flyteidl.admin.EventErrorIncompatibleCluster) + } + + // @@protoc_insertion_point(class_scope:flyteidl.admin.EventErrorIncompatibleCluster) + private static final flyteidl.admin.Event.EventErrorIncompatibleCluster DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new flyteidl.admin.Event.EventErrorIncompatibleCluster(); + } + + public static flyteidl.admin.Event.EventErrorIncompatibleCluster getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public EventErrorIncompatibleCluster parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new EventErrorIncompatibleCluster(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public flyteidl.admin.Event.EventErrorIncompatibleCluster getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + + } + public interface EventFailureReasonOrBuilder extends // @@protoc_insertion_point(interface_extends:flyteidl.admin.EventFailureReason) com.google.protobuf.MessageOrBuilder { @@ -628,6 +1232,19 @@ public interface EventFailureReasonOrBuilder extends */ flyteidl.admin.Event.EventErrorAlreadyInTerminalStateOrBuilder getAlreadyInTerminalStateOrBuilder(); + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + boolean hasIncompatibleCluster(); + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + flyteidl.admin.Event.EventErrorIncompatibleCluster getIncompatibleCluster(); + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder getIncompatibleClusterOrBuilder(); + public flyteidl.admin.Event.EventFailureReason.ReasonCase getReasonCase(); } /** @@ -687,6 +1304,20 @@ private EventFailureReason( reasonCase_ = 1; break; } + case 18: { + flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder subBuilder = null; + if (reasonCase_ == 2) { + subBuilder = ((flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_).toBuilder(); + } + reason_ = + input.readMessage(flyteidl.admin.Event.EventErrorIncompatibleCluster.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom((flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_); + reason_ = subBuilder.buildPartial(); + } + reasonCase_ = 2; + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -724,6 +1355,7 @@ private EventFailureReason( public enum ReasonCase implements com.google.protobuf.Internal.EnumLite { ALREADY_IN_TERMINAL_STATE(1), + INCOMPATIBLE_CLUSTER(2), REASON_NOT_SET(0); private final int value; private ReasonCase(int value) { @@ -740,6 +1372,7 @@ public static ReasonCase valueOf(int value) { public static ReasonCase forNumber(int value) { switch (value) { case 1: return ALREADY_IN_TERMINAL_STATE; + case 2: return INCOMPATIBLE_CLUSTER; case 0: return REASON_NOT_SET; default: return null; } @@ -781,6 +1414,32 @@ public flyteidl.admin.Event.EventErrorAlreadyInTerminalStateOrBuilder getAlready return flyteidl.admin.Event.EventErrorAlreadyInTerminalState.getDefaultInstance(); } + public static final int INCOMPATIBLE_CLUSTER_FIELD_NUMBER = 2; + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public boolean hasIncompatibleCluster() { + return reasonCase_ == 2; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public flyteidl.admin.Event.EventErrorIncompatibleCluster getIncompatibleCluster() { + if (reasonCase_ == 2) { + return (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_; + } + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder getIncompatibleClusterOrBuilder() { + if (reasonCase_ == 2) { + return (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_; + } + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -798,6 +1457,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (reasonCase_ == 1) { output.writeMessage(1, (flyteidl.admin.Event.EventErrorAlreadyInTerminalState) reason_); } + if (reasonCase_ == 2) { + output.writeMessage(2, (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_); + } unknownFields.writeTo(output); } @@ -811,6 +1473,10 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeMessageSize(1, (flyteidl.admin.Event.EventErrorAlreadyInTerminalState) reason_); } + if (reasonCase_ == 2) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(2, (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -832,6 +1498,10 @@ public boolean equals(final java.lang.Object obj) { if (!getAlreadyInTerminalState() .equals(other.getAlreadyInTerminalState())) return false; break; + case 2: + if (!getIncompatibleCluster() + .equals(other.getIncompatibleCluster())) return false; + break; case 0: default: } @@ -851,6 +1521,10 @@ public int hashCode() { hash = (37 * hash) + ALREADY_IN_TERMINAL_STATE_FIELD_NUMBER; hash = (53 * hash) + getAlreadyInTerminalState().hashCode(); break; + case 2: + hash = (37 * hash) + INCOMPATIBLE_CLUSTER_FIELD_NUMBER; + hash = (53 * hash) + getIncompatibleCluster().hashCode(); + break; case 0: default: } @@ -1026,6 +1700,13 @@ public flyteidl.admin.Event.EventFailureReason buildPartial() { result.reason_ = alreadyInTerminalStateBuilder_.build(); } } + if (reasonCase_ == 2) { + if (incompatibleClusterBuilder_ == null) { + result.reason_ = reason_; + } else { + result.reason_ = incompatibleClusterBuilder_.build(); + } + } result.reasonCase_ = reasonCase_; onBuilt(); return result; @@ -1080,6 +1761,10 @@ public Builder mergeFrom(flyteidl.admin.Event.EventFailureReason other) { mergeAlreadyInTerminalState(other.getAlreadyInTerminalState()); break; } + case INCOMPATIBLE_CLUSTER: { + mergeIncompatibleCluster(other.getIncompatibleCluster()); + break; + } case REASON_NOT_SET: { break; } @@ -1263,6 +1948,142 @@ public flyteidl.admin.Event.EventErrorAlreadyInTerminalStateOrBuilder getAlready onChanged();; return alreadyInTerminalStateBuilder_; } + + private com.google.protobuf.SingleFieldBuilderV3< + flyteidl.admin.Event.EventErrorIncompatibleCluster, flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder, flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder> incompatibleClusterBuilder_; + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public boolean hasIncompatibleCluster() { + return reasonCase_ == 2; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public flyteidl.admin.Event.EventErrorIncompatibleCluster getIncompatibleCluster() { + if (incompatibleClusterBuilder_ == null) { + if (reasonCase_ == 2) { + return (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_; + } + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } else { + if (reasonCase_ == 2) { + return incompatibleClusterBuilder_.getMessage(); + } + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public Builder setIncompatibleCluster(flyteidl.admin.Event.EventErrorIncompatibleCluster value) { + if (incompatibleClusterBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + reason_ = value; + onChanged(); + } else { + incompatibleClusterBuilder_.setMessage(value); + } + reasonCase_ = 2; + return this; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public Builder setIncompatibleCluster( + flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder builderForValue) { + if (incompatibleClusterBuilder_ == null) { + reason_ = builderForValue.build(); + onChanged(); + } else { + incompatibleClusterBuilder_.setMessage(builderForValue.build()); + } + reasonCase_ = 2; + return this; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public Builder mergeIncompatibleCluster(flyteidl.admin.Event.EventErrorIncompatibleCluster value) { + if (incompatibleClusterBuilder_ == null) { + if (reasonCase_ == 2 && + reason_ != flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance()) { + reason_ = flyteidl.admin.Event.EventErrorIncompatibleCluster.newBuilder((flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_) + .mergeFrom(value).buildPartial(); + } else { + reason_ = value; + } + onChanged(); + } else { + if (reasonCase_ == 2) { + incompatibleClusterBuilder_.mergeFrom(value); + } + incompatibleClusterBuilder_.setMessage(value); + } + reasonCase_ = 2; + return this; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public Builder clearIncompatibleCluster() { + if (incompatibleClusterBuilder_ == null) { + if (reasonCase_ == 2) { + reasonCase_ = 0; + reason_ = null; + onChanged(); + } + } else { + if (reasonCase_ == 2) { + reasonCase_ = 0; + reason_ = null; + } + incompatibleClusterBuilder_.clear(); + } + return this; + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder getIncompatibleClusterBuilder() { + return getIncompatibleClusterFieldBuilder().getBuilder(); + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + public flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder getIncompatibleClusterOrBuilder() { + if ((reasonCase_ == 2) && (incompatibleClusterBuilder_ != null)) { + return incompatibleClusterBuilder_.getMessageOrBuilder(); + } else { + if (reasonCase_ == 2) { + return (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_; + } + return flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + } + /** + * .flyteidl.admin.EventErrorIncompatibleCluster incompatible_cluster = 2; + */ + private com.google.protobuf.SingleFieldBuilderV3< + flyteidl.admin.Event.EventErrorIncompatibleCluster, flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder, flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder> + getIncompatibleClusterFieldBuilder() { + if (incompatibleClusterBuilder_ == null) { + if (!(reasonCase_ == 2)) { + reason_ = flyteidl.admin.Event.EventErrorIncompatibleCluster.getDefaultInstance(); + } + incompatibleClusterBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + flyteidl.admin.Event.EventErrorIncompatibleCluster, flyteidl.admin.Event.EventErrorIncompatibleCluster.Builder, flyteidl.admin.Event.EventErrorIncompatibleClusterOrBuilder>( + (flyteidl.admin.Event.EventErrorIncompatibleCluster) reason_, + getParentForChildren(), + isClean()); + reason_ = null; + } + reasonCase_ = 2; + onChanged();; + return incompatibleClusterBuilder_; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -5119,6 +5940,11 @@ public flyteidl.admin.Event.TaskExecutionEventResponse getDefaultInstanceForType private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_flyteidl_admin_EventErrorAlreadyInTerminalState_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_flyteidl_admin_EventErrorIncompatibleCluster_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_flyteidl_admin_EventFailureReason_descriptor; private static final @@ -5166,21 +5992,25 @@ public flyteidl.admin.Event.TaskExecutionEventResponse getDefaultInstanceForType "\n\032flyteidl/admin/event.proto\022\016flyteidl.a" + "dmin\032\032flyteidl/event/event.proto\"9\n Even" + "tErrorAlreadyInTerminalState\022\025\n\rcurrent_" + - "phase\030\001 \001(\t\"u\n\022EventFailureReason\022U\n\031alr" + - "eady_in_terminal_state\030\001 \001(\01320.flyteidl." + - "admin.EventErrorAlreadyInTerminalStateH\000" + - "B\010\n\006reason\"j\n\035WorkflowExecutionEventRequ" + - "est\022\022\n\nrequest_id\030\001 \001(\t\0225\n\005event\030\002 \001(\0132&" + - ".flyteidl.event.WorkflowExecutionEvent\" " + - "\n\036WorkflowExecutionEventResponse\"b\n\031Node" + - "ExecutionEventRequest\022\022\n\nrequest_id\030\001 \001(" + - "\t\0221\n\005event\030\002 \001(\0132\".flyteidl.event.NodeEx" + - "ecutionEvent\"\034\n\032NodeExecutionEventRespon" + - "se\"b\n\031TaskExecutionEventRequest\022\022\n\nreque" + + "phase\030\001 \001(\t\"0\n\035EventErrorIncompatibleClu" + + "ster\022\017\n\007cluster\030\001 \001(\t\"\304\001\n\022EventFailureRe" + + "ason\022U\n\031already_in_terminal_state\030\001 \001(\0132" + + "0.flyteidl.admin.EventErrorAlreadyInTerm" + + "inalStateH\000\022M\n\024incompatible_cluster\030\002 \001(" + + "\0132-.flyteidl.admin.EventErrorIncompatibl" + + "eClusterH\000B\010\n\006reason\"j\n\035WorkflowExecutio" + + "nEventRequest\022\022\n\nrequest_id\030\001 \001(\t\0225\n\005eve" + + "nt\030\002 \001(\0132&.flyteidl.event.WorkflowExecut" + + "ionEvent\" \n\036WorkflowExecutionEventRespon" + + "se\"b\n\031NodeExecutionEventRequest\022\022\n\nreque" + "st_id\030\001 \001(\t\0221\n\005event\030\002 \001(\0132\".flyteidl.ev" + - "ent.TaskExecutionEvent\"\034\n\032TaskExecutionE" + - "ventResponseB7Z5github.com/flyteorg/flyt" + - "eidl/gen/pb-go/flyteidl/adminb\006proto3" + "ent.NodeExecutionEvent\"\034\n\032NodeExecutionE" + + "ventResponse\"b\n\031TaskExecutionEventReques" + + "t\022\022\n\nrequest_id\030\001 \001(\t\0221\n\005event\030\002 \001(\0132\".f" + + "lyteidl.event.TaskExecutionEvent\"\034\n\032Task" + + "ExecutionEventResponseB7Z5github.com/fly" + + "teorg/flyteidl/gen/pb-go/flyteidl/adminb" + + "\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { @@ -5201,44 +6031,50 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_EventErrorAlreadyInTerminalState_descriptor, new java.lang.String[] { "CurrentPhase", }); - internal_static_flyteidl_admin_EventFailureReason_descriptor = + internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor = getDescriptor().getMessageTypes().get(1); + internal_static_flyteidl_admin_EventErrorIncompatibleCluster_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_flyteidl_admin_EventErrorIncompatibleCluster_descriptor, + new java.lang.String[] { "Cluster", }); + internal_static_flyteidl_admin_EventFailureReason_descriptor = + getDescriptor().getMessageTypes().get(2); internal_static_flyteidl_admin_EventFailureReason_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_EventFailureReason_descriptor, - new java.lang.String[] { "AlreadyInTerminalState", "Reason", }); + new java.lang.String[] { "AlreadyInTerminalState", "IncompatibleCluster", "Reason", }); internal_static_flyteidl_admin_WorkflowExecutionEventRequest_descriptor = - getDescriptor().getMessageTypes().get(2); + getDescriptor().getMessageTypes().get(3); internal_static_flyteidl_admin_WorkflowExecutionEventRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_WorkflowExecutionEventRequest_descriptor, new java.lang.String[] { "RequestId", "Event", }); internal_static_flyteidl_admin_WorkflowExecutionEventResponse_descriptor = - getDescriptor().getMessageTypes().get(3); + getDescriptor().getMessageTypes().get(4); internal_static_flyteidl_admin_WorkflowExecutionEventResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_WorkflowExecutionEventResponse_descriptor, new java.lang.String[] { }); internal_static_flyteidl_admin_NodeExecutionEventRequest_descriptor = - getDescriptor().getMessageTypes().get(4); + getDescriptor().getMessageTypes().get(5); internal_static_flyteidl_admin_NodeExecutionEventRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_NodeExecutionEventRequest_descriptor, new java.lang.String[] { "RequestId", "Event", }); internal_static_flyteidl_admin_NodeExecutionEventResponse_descriptor = - getDescriptor().getMessageTypes().get(5); + getDescriptor().getMessageTypes().get(6); internal_static_flyteidl_admin_NodeExecutionEventResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_NodeExecutionEventResponse_descriptor, new java.lang.String[] { }); internal_static_flyteidl_admin_TaskExecutionEventRequest_descriptor = - getDescriptor().getMessageTypes().get(6); + getDescriptor().getMessageTypes().get(7); internal_static_flyteidl_admin_TaskExecutionEventRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_TaskExecutionEventRequest_descriptor, new java.lang.String[] { "RequestId", "Event", }); internal_static_flyteidl_admin_TaskExecutionEventResponse_descriptor = - getDescriptor().getMessageTypes().get(7); + getDescriptor().getMessageTypes().get(8); internal_static_flyteidl_admin_TaskExecutionEventResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_flyteidl_admin_TaskExecutionEventResponse_descriptor, diff --git a/flyteidl/gen/pb-js/flyteidl.d.ts b/flyteidl/gen/pb-js/flyteidl.d.ts index 8d4bca8375..abba6712f7 100644 --- a/flyteidl/gen/pb-js/flyteidl.d.ts +++ b/flyteidl/gen/pb-js/flyteidl.d.ts @@ -7807,11 +7807,66 @@ export namespace flyteidl { public static verify(message: { [k: string]: any }): (string|null); } + /** Properties of an EventErrorIncompatibleCluster. */ + interface IEventErrorIncompatibleCluster { + + /** EventErrorIncompatibleCluster cluster */ + cluster?: (string|null); + } + + /** Represents an EventErrorIncompatibleCluster. */ + class EventErrorIncompatibleCluster implements IEventErrorIncompatibleCluster { + + /** + * Constructs a new EventErrorIncompatibleCluster. + * @param [properties] Properties to set + */ + constructor(properties?: flyteidl.admin.IEventErrorIncompatibleCluster); + + /** EventErrorIncompatibleCluster cluster. */ + public cluster: string; + + /** + * Creates a new EventErrorIncompatibleCluster instance using the specified properties. + * @param [properties] Properties to set + * @returns EventErrorIncompatibleCluster instance + */ + public static create(properties?: flyteidl.admin.IEventErrorIncompatibleCluster): flyteidl.admin.EventErrorIncompatibleCluster; + + /** + * Encodes the specified EventErrorIncompatibleCluster message. Does not implicitly {@link flyteidl.admin.EventErrorIncompatibleCluster.verify|verify} messages. + * @param message EventErrorIncompatibleCluster message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encode(message: flyteidl.admin.IEventErrorIncompatibleCluster, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Decodes an EventErrorIncompatibleCluster message from the specified reader or buffer. + * @param reader Reader or buffer to decode from + * @param [length] Message length if known beforehand + * @returns EventErrorIncompatibleCluster + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): flyteidl.admin.EventErrorIncompatibleCluster; + + /** + * Verifies an EventErrorIncompatibleCluster message. + * @param message Plain object to verify + * @returns `null` if valid, otherwise the reason why it is not + */ + public static verify(message: { [k: string]: any }): (string|null); + } + /** Properties of an EventFailureReason. */ interface IEventFailureReason { /** EventFailureReason alreadyInTerminalState */ alreadyInTerminalState?: (flyteidl.admin.IEventErrorAlreadyInTerminalState|null); + + /** EventFailureReason incompatibleCluster */ + incompatibleCluster?: (flyteidl.admin.IEventErrorIncompatibleCluster|null); } /** Represents an EventFailureReason. */ @@ -7826,8 +7881,11 @@ export namespace flyteidl { /** EventFailureReason alreadyInTerminalState. */ public alreadyInTerminalState?: (flyteidl.admin.IEventErrorAlreadyInTerminalState|null); + /** EventFailureReason incompatibleCluster. */ + public incompatibleCluster?: (flyteidl.admin.IEventErrorIncompatibleCluster|null); + /** EventFailureReason reason. */ - public reason?: "alreadyInTerminalState"; + public reason?: ("alreadyInTerminalState"|"incompatibleCluster"); /** * Creates a new EventFailureReason instance using the specified properties. diff --git a/flyteidl/gen/pb-js/flyteidl.js b/flyteidl/gen/pb-js/flyteidl.js index 5599517a60..5f4cc6a673 100644 --- a/flyteidl/gen/pb-js/flyteidl.js +++ b/flyteidl/gen/pb-js/flyteidl.js @@ -18797,6 +18797,116 @@ export const flyteidl = $root.flyteidl = (() => { return EventErrorAlreadyInTerminalState; })(); + admin.EventErrorIncompatibleCluster = (function() { + + /** + * Properties of an EventErrorIncompatibleCluster. + * @memberof flyteidl.admin + * @interface IEventErrorIncompatibleCluster + * @property {string|null} [cluster] EventErrorIncompatibleCluster cluster + */ + + /** + * Constructs a new EventErrorIncompatibleCluster. + * @memberof flyteidl.admin + * @classdesc Represents an EventErrorIncompatibleCluster. + * @implements IEventErrorIncompatibleCluster + * @constructor + * @param {flyteidl.admin.IEventErrorIncompatibleCluster=} [properties] Properties to set + */ + function EventErrorIncompatibleCluster(properties) { + if (properties) + for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i) + if (properties[keys[i]] != null) + this[keys[i]] = properties[keys[i]]; + } + + /** + * EventErrorIncompatibleCluster cluster. + * @member {string} cluster + * @memberof flyteidl.admin.EventErrorIncompatibleCluster + * @instance + */ + EventErrorIncompatibleCluster.prototype.cluster = ""; + + /** + * Creates a new EventErrorIncompatibleCluster instance using the specified properties. + * @function create + * @memberof flyteidl.admin.EventErrorIncompatibleCluster + * @static + * @param {flyteidl.admin.IEventErrorIncompatibleCluster=} [properties] Properties to set + * @returns {flyteidl.admin.EventErrorIncompatibleCluster} EventErrorIncompatibleCluster instance + */ + EventErrorIncompatibleCluster.create = function create(properties) { + return new EventErrorIncompatibleCluster(properties); + }; + + /** + * Encodes the specified EventErrorIncompatibleCluster message. Does not implicitly {@link flyteidl.admin.EventErrorIncompatibleCluster.verify|verify} messages. + * @function encode + * @memberof flyteidl.admin.EventErrorIncompatibleCluster + * @static + * @param {flyteidl.admin.IEventErrorIncompatibleCluster} message EventErrorIncompatibleCluster message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + EventErrorIncompatibleCluster.encode = function encode(message, writer) { + if (!writer) + writer = $Writer.create(); + if (message.cluster != null && message.hasOwnProperty("cluster")) + writer.uint32(/* id 1, wireType 2 =*/10).string(message.cluster); + return writer; + }; + + /** + * Decodes an EventErrorIncompatibleCluster message from the specified reader or buffer. + * @function decode + * @memberof flyteidl.admin.EventErrorIncompatibleCluster + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @param {number} [length] Message length if known beforehand + * @returns {flyteidl.admin.EventErrorIncompatibleCluster} EventErrorIncompatibleCluster + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + EventErrorIncompatibleCluster.decode = function decode(reader, length) { + if (!(reader instanceof $Reader)) + reader = $Reader.create(reader); + let end = length === undefined ? reader.len : reader.pos + length, message = new $root.flyteidl.admin.EventErrorIncompatibleCluster(); + while (reader.pos < end) { + let tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.cluster = reader.string(); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }; + + /** + * Verifies an EventErrorIncompatibleCluster message. + * @function verify + * @memberof flyteidl.admin.EventErrorIncompatibleCluster + * @static + * @param {Object.} message Plain object to verify + * @returns {string|null} `null` if valid, otherwise the reason why it is not + */ + EventErrorIncompatibleCluster.verify = function verify(message) { + if (typeof message !== "object" || message === null) + return "object expected"; + if (message.cluster != null && message.hasOwnProperty("cluster")) + if (!$util.isString(message.cluster)) + return "cluster: string expected"; + return null; + }; + + return EventErrorIncompatibleCluster; + })(); + admin.EventFailureReason = (function() { /** @@ -18804,6 +18914,7 @@ export const flyteidl = $root.flyteidl = (() => { * @memberof flyteidl.admin * @interface IEventFailureReason * @property {flyteidl.admin.IEventErrorAlreadyInTerminalState|null} [alreadyInTerminalState] EventFailureReason alreadyInTerminalState + * @property {flyteidl.admin.IEventErrorIncompatibleCluster|null} [incompatibleCluster] EventFailureReason incompatibleCluster */ /** @@ -18829,17 +18940,25 @@ export const flyteidl = $root.flyteidl = (() => { */ EventFailureReason.prototype.alreadyInTerminalState = null; + /** + * EventFailureReason incompatibleCluster. + * @member {flyteidl.admin.IEventErrorIncompatibleCluster|null|undefined} incompatibleCluster + * @memberof flyteidl.admin.EventFailureReason + * @instance + */ + EventFailureReason.prototype.incompatibleCluster = null; + // OneOf field names bound to virtual getters and setters let $oneOfFields; /** * EventFailureReason reason. - * @member {"alreadyInTerminalState"|undefined} reason + * @member {"alreadyInTerminalState"|"incompatibleCluster"|undefined} reason * @memberof flyteidl.admin.EventFailureReason * @instance */ Object.defineProperty(EventFailureReason.prototype, "reason", { - get: $util.oneOfGetter($oneOfFields = ["alreadyInTerminalState"]), + get: $util.oneOfGetter($oneOfFields = ["alreadyInTerminalState", "incompatibleCluster"]), set: $util.oneOfSetter($oneOfFields) }); @@ -18869,6 +18988,8 @@ export const flyteidl = $root.flyteidl = (() => { writer = $Writer.create(); if (message.alreadyInTerminalState != null && message.hasOwnProperty("alreadyInTerminalState")) $root.flyteidl.admin.EventErrorAlreadyInTerminalState.encode(message.alreadyInTerminalState, writer.uint32(/* id 1, wireType 2 =*/10).fork()).ldelim(); + if (message.incompatibleCluster != null && message.hasOwnProperty("incompatibleCluster")) + $root.flyteidl.admin.EventErrorIncompatibleCluster.encode(message.incompatibleCluster, writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim(); return writer; }; @@ -18893,6 +19014,9 @@ export const flyteidl = $root.flyteidl = (() => { case 1: message.alreadyInTerminalState = $root.flyteidl.admin.EventErrorAlreadyInTerminalState.decode(reader, reader.uint32()); break; + case 2: + message.incompatibleCluster = $root.flyteidl.admin.EventErrorIncompatibleCluster.decode(reader, reader.uint32()); + break; default: reader.skipType(tag & 7); break; @@ -18921,6 +19045,16 @@ export const flyteidl = $root.flyteidl = (() => { return "alreadyInTerminalState." + error; } } + if (message.incompatibleCluster != null && message.hasOwnProperty("incompatibleCluster")) { + if (properties.reason === 1) + return "reason: multiple values"; + properties.reason = 1; + { + let error = $root.flyteidl.admin.EventErrorIncompatibleCluster.verify(message.incompatibleCluster); + if (error) + return "incompatibleCluster." + error; + } + } return null; }; diff --git a/flyteidl/gen/pb_python/flyteidl/admin/event_pb2.py b/flyteidl/gen/pb_python/flyteidl/admin/event_pb2.py index 24803018dc..64d6f7f161 100644 --- a/flyteidl/gen/pb_python/flyteidl/admin/event_pb2.py +++ b/flyteidl/gen/pb_python/flyteidl/admin/event_pb2.py @@ -21,7 +21,7 @@ package='flyteidl.admin', syntax='proto3', serialized_options=_b('Z5github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/admin'), - serialized_pb=_b('\n\x1a\x66lyteidl/admin/event.proto\x12\x0e\x66lyteidl.admin\x1a\x1a\x66lyteidl/event/event.proto\"9\n EventErrorAlreadyInTerminalState\x12\x15\n\rcurrent_phase\x18\x01 \x01(\t\"u\n\x12\x45ventFailureReason\x12U\n\x19\x61lready_in_terminal_state\x18\x01 \x01(\x0b\x32\x30.flyteidl.admin.EventErrorAlreadyInTerminalStateH\x00\x42\x08\n\x06reason\"j\n\x1dWorkflowExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x35\n\x05\x65vent\x18\x02 \x01(\x0b\x32&.flyteidl.event.WorkflowExecutionEvent\" \n\x1eWorkflowExecutionEventResponse\"b\n\x19NodeExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x31\n\x05\x65vent\x18\x02 \x01(\x0b\x32\".flyteidl.event.NodeExecutionEvent\"\x1c\n\x1aNodeExecutionEventResponse\"b\n\x19TaskExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x31\n\x05\x65vent\x18\x02 \x01(\x0b\x32\".flyteidl.event.TaskExecutionEvent\"\x1c\n\x1aTaskExecutionEventResponseB7Z5github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/adminb\x06proto3') + serialized_pb=_b('\n\x1a\x66lyteidl/admin/event.proto\x12\x0e\x66lyteidl.admin\x1a\x1a\x66lyteidl/event/event.proto\"9\n EventErrorAlreadyInTerminalState\x12\x15\n\rcurrent_phase\x18\x01 \x01(\t\"0\n\x1d\x45ventErrorIncompatibleCluster\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\"\xc4\x01\n\x12\x45ventFailureReason\x12U\n\x19\x61lready_in_terminal_state\x18\x01 \x01(\x0b\x32\x30.flyteidl.admin.EventErrorAlreadyInTerminalStateH\x00\x12M\n\x14incompatible_cluster\x18\x02 \x01(\x0b\x32-.flyteidl.admin.EventErrorIncompatibleClusterH\x00\x42\x08\n\x06reason\"j\n\x1dWorkflowExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x35\n\x05\x65vent\x18\x02 \x01(\x0b\x32&.flyteidl.event.WorkflowExecutionEvent\" \n\x1eWorkflowExecutionEventResponse\"b\n\x19NodeExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x31\n\x05\x65vent\x18\x02 \x01(\x0b\x32\".flyteidl.event.NodeExecutionEvent\"\x1c\n\x1aNodeExecutionEventResponse\"b\n\x19TaskExecutionEventRequest\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\x31\n\x05\x65vent\x18\x02 \x01(\x0b\x32\".flyteidl.event.TaskExecutionEvent\"\x1c\n\x1aTaskExecutionEventResponseB7Z5github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/adminb\x06proto3') , dependencies=[flyteidl_dot_event_dot_event__pb2.DESCRIPTOR,]) @@ -59,6 +59,37 @@ ) +_EVENTERRORINCOMPATIBLECLUSTER = _descriptor.Descriptor( + name='EventErrorIncompatibleCluster', + full_name='flyteidl.admin.EventErrorIncompatibleCluster', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='cluster', full_name='flyteidl.admin.EventErrorIncompatibleCluster.cluster', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=_b("").decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=133, + serialized_end=181, +) + + _EVENTFAILUREREASON = _descriptor.Descriptor( name='EventFailureReason', full_name='flyteidl.admin.EventFailureReason', @@ -73,6 +104,13 @@ message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, serialized_options=None, file=DESCRIPTOR), + _descriptor.FieldDescriptor( + name='incompatible_cluster', full_name='flyteidl.admin.EventFailureReason.incompatible_cluster', index=1, + number=2, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -88,8 +126,8 @@ name='reason', full_name='flyteidl.admin.EventFailureReason.reason', index=0, containing_type=None, fields=[]), ], - serialized_start=133, - serialized_end=250, + serialized_start=184, + serialized_end=380, ) @@ -126,8 +164,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=252, - serialized_end=358, + serialized_start=382, + serialized_end=488, ) @@ -150,8 +188,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=360, - serialized_end=392, + serialized_start=490, + serialized_end=522, ) @@ -188,8 +226,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=394, - serialized_end=492, + serialized_start=524, + serialized_end=622, ) @@ -212,8 +250,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=494, - serialized_end=522, + serialized_start=624, + serialized_end=652, ) @@ -250,8 +288,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=524, - serialized_end=622, + serialized_start=654, + serialized_end=752, ) @@ -274,18 +312,23 @@ extension_ranges=[], oneofs=[ ], - serialized_start=624, - serialized_end=652, + serialized_start=754, + serialized_end=782, ) _EVENTFAILUREREASON.fields_by_name['already_in_terminal_state'].message_type = _EVENTERRORALREADYINTERMINALSTATE +_EVENTFAILUREREASON.fields_by_name['incompatible_cluster'].message_type = _EVENTERRORINCOMPATIBLECLUSTER _EVENTFAILUREREASON.oneofs_by_name['reason'].fields.append( _EVENTFAILUREREASON.fields_by_name['already_in_terminal_state']) _EVENTFAILUREREASON.fields_by_name['already_in_terminal_state'].containing_oneof = _EVENTFAILUREREASON.oneofs_by_name['reason'] +_EVENTFAILUREREASON.oneofs_by_name['reason'].fields.append( + _EVENTFAILUREREASON.fields_by_name['incompatible_cluster']) +_EVENTFAILUREREASON.fields_by_name['incompatible_cluster'].containing_oneof = _EVENTFAILUREREASON.oneofs_by_name['reason'] _WORKFLOWEXECUTIONEVENTREQUEST.fields_by_name['event'].message_type = flyteidl_dot_event_dot_event__pb2._WORKFLOWEXECUTIONEVENT _NODEEXECUTIONEVENTREQUEST.fields_by_name['event'].message_type = flyteidl_dot_event_dot_event__pb2._NODEEXECUTIONEVENT _TASKEXECUTIONEVENTREQUEST.fields_by_name['event'].message_type = flyteidl_dot_event_dot_event__pb2._TASKEXECUTIONEVENT DESCRIPTOR.message_types_by_name['EventErrorAlreadyInTerminalState'] = _EVENTERRORALREADYINTERMINALSTATE +DESCRIPTOR.message_types_by_name['EventErrorIncompatibleCluster'] = _EVENTERRORINCOMPATIBLECLUSTER DESCRIPTOR.message_types_by_name['EventFailureReason'] = _EVENTFAILUREREASON DESCRIPTOR.message_types_by_name['WorkflowExecutionEventRequest'] = _WORKFLOWEXECUTIONEVENTREQUEST DESCRIPTOR.message_types_by_name['WorkflowExecutionEventResponse'] = _WORKFLOWEXECUTIONEVENTRESPONSE @@ -302,6 +345,13 @@ )) _sym_db.RegisterMessage(EventErrorAlreadyInTerminalState) +EventErrorIncompatibleCluster = _reflection.GeneratedProtocolMessageType('EventErrorIncompatibleCluster', (_message.Message,), dict( + DESCRIPTOR = _EVENTERRORINCOMPATIBLECLUSTER, + __module__ = 'flyteidl.admin.event_pb2' + # @@protoc_insertion_point(class_scope:flyteidl.admin.EventErrorIncompatibleCluster) + )) +_sym_db.RegisterMessage(EventErrorIncompatibleCluster) + EventFailureReason = _reflection.GeneratedProtocolMessageType('EventFailureReason', (_message.Message,), dict( DESCRIPTOR = _EVENTFAILUREREASON, __module__ = 'flyteidl.admin.event_pb2' diff --git a/flyteidl/protos/docs/admin/admin.rst b/flyteidl/protos/docs/admin/admin.rst index 88805e137b..01d69d4ce3 100644 --- a/flyteidl/protos/docs/admin/admin.rst +++ b/flyteidl/protos/docs/admin/admin.rst @@ -634,6 +634,28 @@ for further state transitions). +.. _ref_flyteidl.admin.EventErrorIncompatibleCluster: + +EventErrorIncompatibleCluster +------------------------------------------------------------------ + +Indicates an event was rejected because it came from a different cluster than +is on record as running the execution. + + + +.. csv-table:: EventErrorIncompatibleCluster type fields + :header: "Field", "Type", "Label", "Description" + :widths: auto + + "cluster", ":ref:`ref_string`", "", "The cluster which has been recorded as processing the execution. +required" + + + + + + + .. _ref_flyteidl.admin.EventFailureReason: EventFailureReason @@ -648,6 +670,7 @@ Indicates why a sent event was not used to update execution. :widths: auto "already_in_terminal_state", ":ref:`ref_flyteidl.admin.EventErrorAlreadyInTerminalState`", "", "" + "incompatible_cluster", ":ref:`ref_flyteidl.admin.EventErrorIncompatibleCluster`", "", "" diff --git a/flyteidl/protos/flyteidl/admin/event.proto b/flyteidl/protos/flyteidl/admin/event.proto index a16038068e..483454921e 100644 --- a/flyteidl/protos/flyteidl/admin/event.proto +++ b/flyteidl/protos/flyteidl/admin/event.proto @@ -13,11 +13,20 @@ message EventErrorAlreadyInTerminalState { string current_phase = 1; } +// Indicates an event was rejected because it came from a different cluster than +// is on record as running the execution. +message EventErrorIncompatibleCluster { + // The cluster which has been recorded as processing the execution. + // +required + string cluster = 1; +} + // Indicates why a sent event was not used to update execution. message EventFailureReason { // +required oneof reason { EventErrorAlreadyInTerminalState already_in_terminal_state = 1; + EventErrorIncompatibleCluster incompatible_cluster = 2; } }