|
|
|
@@ -143,17 +143,17 @@ async fn run( |
|
|
|
} |
|
|
|
OperatorEvent::Finished { reason } => { |
|
|
|
if let StopReason::ExplicitStopAll = reason { |
|
|
|
let hlc = dora_core::message::uhlc::HLC::default(); |
|
|
|
let metadata = dora_core::message::Metadata::new(hlc.new_timestamp()); |
|
|
|
let data = metadata |
|
|
|
.serialize() |
|
|
|
.wrap_err("failed to serialize stop message")?; |
|
|
|
// let hlc = dora_core::message::uhlc::HLC::default(); |
|
|
|
// let metadata = dora_core::message::Metadata::new(hlc.new_timestamp()); |
|
|
|
// let data = metadata |
|
|
|
// .serialize() |
|
|
|
// .wrap_err("failed to serialize stop message")?; |
|
|
|
todo!("instruct dora-daemon/dora-coordinator to stop other nodes"); |
|
|
|
// manual_stop_publisher |
|
|
|
// .publish(&data) |
|
|
|
// .map_err(|err| eyre::eyre!(err)) |
|
|
|
// .wrap_err("failed to send stop message")?; |
|
|
|
break; |
|
|
|
// break; |
|
|
|
} |
|
|
|
|
|
|
|
let Some(config) = operators.get(&operator_id) else { |
|
|
|
|