Skip to content

Commit 7d6c5ab

Browse files
committed
Update protos and ops for TensorFlow 2.17.0
1 parent abb3131 commit 7d6c5ab

File tree

12 files changed

+22557
-1390
lines changed

12 files changed

+22557
-1390
lines changed

src/eager/op/raw_ops.rs

Lines changed: 8072 additions & 277 deletions
Large diffs are not rendered by default.

src/ops/ops_impl.rs

Lines changed: 12983 additions & 691 deletions
Large diffs are not rendered by default.

src/protos/config.rs

Lines changed: 803 additions & 158 deletions
Large diffs are not rendered by default.

src/protos/coordination_config.rs

Lines changed: 54 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
#![allow(trivial_casts)]
1818
#![allow(unused_imports)]
1919
#![allow(unused_results)]
20-
//! Generated file from `tensorflow/tsl/protobuf/coordination_config.proto`
20+
//! Generated file from `tsl/protobuf/coordination_config.proto`
2121
2222
/// Generated files are compatible only with the same version
2323
/// of protobuf runtime.
@@ -230,6 +230,7 @@ pub struct CoordinationServiceConfig {
230230
pub agent_destruction_without_shutdown: bool,
231231
pub recoverable_jobs: ::protobuf::RepeatedField<::std::string::String>,
232232
pub allow_new_incarnation_to_reconnect: bool,
233+
pub force_disable: bool,
233234
// special fields
234235
pub unknown_fields: ::protobuf::UnknownFields,
235236
pub cached_size: ::protobuf::CachedSize,
@@ -437,6 +438,21 @@ impl CoordinationServiceConfig {
437438
pub fn set_allow_new_incarnation_to_reconnect(&mut self, v: bool) {
438439
self.allow_new_incarnation_to_reconnect = v;
439440
}
441+
442+
// bool force_disable = 12;
443+
444+
445+
pub fn get_force_disable(&self) -> bool {
446+
self.force_disable
447+
}
448+
pub fn clear_force_disable(&mut self) {
449+
self.force_disable = false;
450+
}
451+
452+
// Param is passed by value, moved
453+
pub fn set_force_disable(&mut self, v: bool) {
454+
self.force_disable = v;
455+
}
440456
}
441457

442458
impl ::protobuf::Message for CoordinationServiceConfig {
@@ -507,6 +523,13 @@ impl ::protobuf::Message for CoordinationServiceConfig {
507523
let tmp = is.read_bool()?;
508524
self.allow_new_incarnation_to_reconnect = tmp;
509525
},
526+
12 => {
527+
if wire_type != ::protobuf::wire_format::WireTypeVarint {
528+
return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
529+
}
530+
let tmp = is.read_bool()?;
531+
self.force_disable = tmp;
532+
},
510533
_ => {
511534
::protobuf::rt::read_unknown_or_skip_group(field_number, wire_type, is, self.mut_unknown_fields())?;
512535
},
@@ -550,6 +573,9 @@ impl ::protobuf::Message for CoordinationServiceConfig {
550573
if self.allow_new_incarnation_to_reconnect != false {
551574
my_size += 2;
552575
}
576+
if self.force_disable != false {
577+
my_size += 2;
578+
}
553579
my_size += ::protobuf::rt::unknown_fields_size(self.get_unknown_fields());
554580
self.cached_size.set(my_size);
555581
my_size
@@ -588,6 +614,9 @@ impl ::protobuf::Message for CoordinationServiceConfig {
588614
if self.allow_new_incarnation_to_reconnect != false {
589615
os.write_bool(11, self.allow_new_incarnation_to_reconnect)?;
590616
}
617+
if self.force_disable != false {
618+
os.write_bool(12, self.force_disable)?;
619+
}
591620
os.write_unknown_fields(self.get_unknown_fields())?;
592621
::std::result::Result::Ok(())
593622
}
@@ -676,6 +705,11 @@ impl ::protobuf::Message for CoordinationServiceConfig {
676705
|m: &CoordinationServiceConfig| { &m.allow_new_incarnation_to_reconnect },
677706
|m: &mut CoordinationServiceConfig| { &mut m.allow_new_incarnation_to_reconnect },
678707
));
708+
fields.push(::protobuf::reflect::accessor::make_simple_field_accessor::<_, ::protobuf::types::ProtobufTypeBool>(
709+
"force_disable",
710+
|m: &CoordinationServiceConfig| { &m.force_disable },
711+
|m: &mut CoordinationServiceConfig| { &mut m.force_disable },
712+
));
679713
::protobuf::reflect::MessageDescriptor::new_pb_name::<CoordinationServiceConfig>(
680714
"CoordinationServiceConfig",
681715
fields,
@@ -702,6 +736,7 @@ impl ::protobuf::Clear for CoordinationServiceConfig {
702736
self.agent_destruction_without_shutdown = false;
703737
self.recoverable_jobs.clear();
704738
self.allow_new_incarnation_to_reconnect = false;
739+
self.force_disable = false;
705740
self.unknown_fields.clear();
706741
}
707742
}
@@ -719,23 +754,24 @@ impl ::protobuf::reflect::ProtobufValue for CoordinationServiceConfig {
719754
}
720755

721756
static file_descriptor_proto_data: &'static [u8] = b"\
722-
\n1tensorflow/tsl/protobuf/coordination_config.proto\x12\ntensorflow\"A\
723-
\n\x0eCoordinatedJob\x12\x12\n\x04name\x18\x01\x20\x01(\tR\x04name\x12\
724-
\x1b\n\tnum_tasks\x18\x02\x20\x01(\x05R\x08numTasks\"\xec\x04\n\x19Coord\
725-
inationServiceConfig\x12!\n\x0cservice_type\x18\x01\x20\x01(\tR\x0bservi\
726-
ceType\x12%\n\x0eservice_leader\x18\x02\x20\x01(\tR\rserviceLeader\x12.\
727-
\n\x13enable_health_check\x18\x03\x20\x01(\x08R\x11enableHealthCheck\x12\
728-
B\n\x1ecluster_register_timeout_in_ms\x18\x04\x20\x01(\x03R\x1aclusterRe\
729-
gisterTimeoutInMs\x125\n\x17heartbeat_timeout_in_ms\x18\x05\x20\x01(\x03\
730-
R\x14heartbeatTimeoutInMs\x12L\n\x14coordinated_job_list\x18\n\x20\x03(\
731-
\x0b2\x1a.tensorflow.CoordinatedJobR\x12coordinatedJobList\x12B\n\x1eshu\
732-
tdown_barrier_timeout_in_ms\x18\x07\x20\x01(\x03R\x1ashutdownBarrierTime\
733-
outInMs\x12K\n\"agent_destruction_without_shutdown\x18\x08\x20\x01(\x08R\
734-
\x1fagentDestructionWithoutShutdown\x12)\n\x10recoverable_jobs\x18\t\x20\
735-
\x03(\tR\x0frecoverableJobs\x12J\n\"allow_new_incarnation_to_reconnect\
736-
\x18\x0b\x20\x01(\x08R\x1eallowNewIncarnationToReconnectJ\x04\x08\x06\
737-
\x10\x07BWZUgithub.com/tensorflow/tensorflow/tensorflow/go/core/protobuf\
738-
/for_core_protos_go_protob\x06proto3\
757+
\n&tsl/protobuf/coordination_config.proto\x12\ntensorflow\"A\n\x0eCoordi\
758+
natedJob\x12\x12\n\x04name\x18\x01\x20\x01(\tR\x04name\x12\x1b\n\tnum_ta\
759+
sks\x18\x02\x20\x01(\x05R\x08numTasks\"\x91\x05\n\x19CoordinationService\
760+
Config\x12!\n\x0cservice_type\x18\x01\x20\x01(\tR\x0bserviceType\x12%\n\
761+
\x0eservice_leader\x18\x02\x20\x01(\tR\rserviceLeader\x12.\n\x13enable_h\
762+
ealth_check\x18\x03\x20\x01(\x08R\x11enableHealthCheck\x12B\n\x1ecluster\
763+
_register_timeout_in_ms\x18\x04\x20\x01(\x03R\x1aclusterRegisterTimeoutI\
764+
nMs\x125\n\x17heartbeat_timeout_in_ms\x18\x05\x20\x01(\x03R\x14heartbeat\
765+
TimeoutInMs\x12L\n\x14coordinated_job_list\x18\n\x20\x03(\x0b2\x1a.tenso\
766+
rflow.CoordinatedJobR\x12coordinatedJobList\x12B\n\x1eshutdown_barrier_t\
767+
imeout_in_ms\x18\x07\x20\x01(\x03R\x1ashutdownBarrierTimeoutInMs\x12K\n\
768+
\"agent_destruction_without_shutdown\x18\x08\x20\x01(\x08R\x1fagentDestr\
769+
uctionWithoutShutdown\x12)\n\x10recoverable_jobs\x18\t\x20\x03(\tR\x0fre\
770+
coverableJobs\x12J\n\"allow_new_incarnation_to_reconnect\x18\x0b\x20\x01\
771+
(\x08R\x1eallowNewIncarnationToReconnect\x12#\n\rforce_disable\x18\x0c\
772+
\x20\x01(\x08R\x0cforceDisableJ\x04\x08\x06\x10\x07BWZUgithub.com/tensor\
773+
flow/tensorflow/tensorflow/go/core/protobuf/for_core_protos_go_protob\
774+
\x06proto3\
739775
";
740776

741777
static file_descriptor_proto_lazy: ::protobuf::rt::LazyV2<::protobuf::descriptor::FileDescriptorProto> = ::protobuf::rt::LazyV2::INIT;

0 commit comments

Comments
 (0)