|
@@ -8497,6 +8497,7 @@ $root.tensorflow.CoordinationServiceConfig = class CoordinationServiceConfig {
|
|
|
|
|
|
|
|
constructor() {
|
|
constructor() {
|
|
|
this.coordinated_jobs = [];
|
|
this.coordinated_jobs = [];
|
|
|
|
|
+ this.recoverable_jobs = [];
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static decode(reader, length) {
|
|
static decode(reader, length) {
|
|
@@ -8529,6 +8530,9 @@ $root.tensorflow.CoordinationServiceConfig = class CoordinationServiceConfig {
|
|
|
case 8:
|
|
case 8:
|
|
|
message.agent_destruction_without_shutdown = reader.bool();
|
|
message.agent_destruction_without_shutdown = reader.bool();
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case 9:
|
|
|
|
|
+ message.recoverable_jobs.push(reader.string());
|
|
|
|
|
+ break;
|
|
|
default:
|
|
default:
|
|
|
reader.skipType(tag & 7);
|
|
reader.skipType(tag & 7);
|
|
|
break;
|
|
break;
|
|
@@ -8567,6 +8571,9 @@ $root.tensorflow.CoordinationServiceConfig = class CoordinationServiceConfig {
|
|
|
case "agent_destruction_without_shutdown":
|
|
case "agent_destruction_without_shutdown":
|
|
|
message.agent_destruction_without_shutdown = reader.bool();
|
|
message.agent_destruction_without_shutdown = reader.bool();
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case "recoverable_jobs":
|
|
|
|
|
+ reader.array(message.recoverable_jobs, () => reader.string());
|
|
|
|
|
+ break;
|
|
|
default:
|
|
default:
|
|
|
reader.field(tag, message);
|
|
reader.field(tag, message);
|
|
|
break;
|
|
break;
|