We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ce95a4f commit 4899436Copy full SHA for 4899436
gaia-stub/proto/cop.proto
@@ -118,7 +118,8 @@ enum CopTaskStatusPattern {
118
message CopWorkerStatus {
119
CopWorkerStatusPattern state = 1;
120
uint64 timeout_sec = 2;
121
- google.protobuf.Timestamp timestamp = 3;
+ uint32 max_executing = 3;
122
+ google.protobuf.Timestamp timestamp = 4;
123
}
124
125
enum CopWorkerStatusPattern {
tmtc-c2a/src/fop/state_machine.rs
@@ -95,6 +95,7 @@ impl FopStateContext {
95
if let Err(e) = self.worker_state_tx.send(CopWorkerStatus {
96
state: status.into(),
97
timeout_sec: self.timeout_sec.into(),
98
+ max_executing: self.max_executing as u32,
99
timestamp: Some(timestamp),
100
}).await {
101
error!("failed to send FOP state: {}", e);
0 commit comments