6e37586 feat: log when looking for events to process, or waiting to pick — radicle-ci-broker

Radicle CI broker

feat: log when looking for events to process, or waiting to pick

Lars Wirzenius committed 1 year ago

commit 6e375867009679f98da44b82c1b517c66337007d
parent 0bbfebc80da0796f92456f01f814e19886c4ef39

1 file changed +5 -0

modified src/queueproc.rs

@@ -60,6 +60,7 @@ impl QueueProcessor {

     fn process_until_shutdown(&mut self) -> Result<(), QueueError> {
         let mut done = false;
         while !done {
             info!("Looking for an event to process");
             if let Some(qe) = self.pick_event()? {
                 info!("picked event from queue: {}", qe.id());
                 done = self.process_event(qe.event())?;

@@ -125,6 +126,10 @@ impl QueueProcessor {

     }
     fn wait_for_events(&self) {
         info!(
             "wait about {} seconds to check for events to process",
             WAIT_FOR_EVENTS_DURATION.as_secs()
         );
         sleep(WAIT_FOR_EVENTS_DURATION);
     }
 }