Remove useless code
This commit is contained in:
parent
e66776cee8
commit
d1c2512a2d
|
@ -20,7 +20,8 @@ use ofborg::tasks;
|
|||
|
||||
fn main() {
|
||||
let cfg = config::load(env::args().nth(1).unwrap().as_ref());
|
||||
env_logger::init();
|
||||
ofborg::setup_log();
|
||||
|
||||
println!("Hello, world!");
|
||||
|
||||
|
||||
|
|
|
@ -1,7 +1,5 @@
|
|||
use ofborg::message::{Pr, Repo};
|
||||
use ofborg::message::buildresult;
|
||||
use ofborg::commentparser::Subset;
|
||||
use ofborg::worker;
|
||||
use serde_json;
|
||||
|
||||
#[derive(Serialize, Deserialize, Debug)]
|
||||
|
|
|
@ -1,4 +1,3 @@
|
|||
use ofborg::message::{Pr, Repo};
|
||||
|
||||
#[derive(Serialize, Deserialize, Debug)]
|
||||
pub struct BuildLogMsg {
|
||||
|
|
|
@ -68,9 +68,10 @@ impl<E: stats::SysEvents> worker::SimpleWorker for MassRebuildWorker<E> {
|
|||
}
|
||||
Err(e) => {
|
||||
self.events.tick("job-decode-failure");
|
||||
println!(
|
||||
"Failed to decode message: {:?}",
|
||||
String::from_utf8(body.clone())
|
||||
error!(
|
||||
"Failed to decode message: {:?}, Err: {:?}",
|
||||
String::from_utf8(body.clone()),
|
||||
e
|
||||
);
|
||||
Err("Failed to decode message".to_owned())
|
||||
}
|
||||
|
|
|
@ -4,7 +4,6 @@ use amqp::protocol::basic::{Deliver, BasicProperties};
|
|||
use std::marker::Send;
|
||||
use serde::Serialize;
|
||||
use serde_json;
|
||||
use std::cmp::PartialEq;
|
||||
|
||||
pub struct Worker<T: SimpleWorker> {
|
||||
internal: T,
|
||||
|
|
Loading…
Reference in a new issue