danderson/ofborg
0
0
Fork 0
forked from the-distro/ofborg
Code Pull requests Activity

bin/mass-rebuilder: use whoami() to identify rabbitmq

Browse source
This commit is contained in:
Cole Helbling 2022-03-05 12:35:22 -08:00
parent b60e30cd42
commit 3d7a81300b
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
ofborg/src/bin/mass-rebuilder.rs
View file

@ -38,10 +38,7 @@ fn main() -> Result<(), Box<dyn Error>> {
let cloner = checkout::cached_cloner(Path::new(&cfg.checkout.root)); let cloner = checkout::cached_cloner(Path::new(&cfg.checkout.root));
let nix = cfg.nix(); let nix = cfg.nix();
let events = stats::RabbitMq::from_lapin( let events = stats::RabbitMq::from_lapin(&cfg.whoami(), task::block_on(conn.create_channel())?);
&format!("{}-{}", cfg.runner.identity, cfg.nix.system),
task::block_on(conn.create_channel())?,
);
let queue_name = String::from("mass-rebuild-check-jobs"); let queue_name = String::from("mass-rebuild-check-jobs");
chan.declare_queue(easyamqp::QueueConfig { chan.declare_queue(easyamqp::QueueConfig {