Box MsgType::Finish(BuildResult)
This commit is contained in:
parent
d49bd4495a
commit
63fcd856da
1 changed files with 2 additions and 2 deletions
|
@ -28,7 +28,7 @@ pub struct LogMessageCollector {
|
||||||
enum MsgType {
|
enum MsgType {
|
||||||
Start(BuildLogStart),
|
Start(BuildLogStart),
|
||||||
Msg(BuildLogMsg),
|
Msg(BuildLogMsg),
|
||||||
Finish(BuildResult),
|
Finish(Box<BuildResult>),
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
|
@ -197,7 +197,7 @@ impl worker::SimpleWorker for LogMessageCollector {
|
||||||
let decode_msg: Result<BuildResult, _> = serde_json::from_slice(body);
|
let decode_msg: Result<BuildResult, _> = serde_json::from_slice(body);
|
||||||
if let Ok(msg) = decode_msg {
|
if let Ok(msg) = decode_msg {
|
||||||
attempt_id = msg.legacy().attempt_id.clone();
|
attempt_id = msg.legacy().attempt_id.clone();
|
||||||
message = MsgType::Finish(msg);
|
message = MsgType::Finish(Box::new(msg));
|
||||||
} else {
|
} else {
|
||||||
return Err(format!("failed to decode job: {:?}", decode_msg));
|
return Err(format!("failed to decode job: {:?}", decode_msg));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue