c537e57 feat: if the event queue a shutdown event, always pick it first — radicle-ci-broker

rad:zwTxygwuz5LDGBq255RA2CbNGrz8

Radicle CI broker

feat: if the event queue a shutdown event, always pick it first

Lars Wirzenius committed 5 months ago

commit c537e57dd63eacd8cf82dca196960ac7ea781799
parent 5d8d60b

1 file changed +5 -0

modified src/queueproc.rs

@@ -243,6 +243,11 @@ impl QueueProcessor {

         let mut queue = vec![];
         for id in ids.iter() {
             if let Some(qe) = self.db.get_queued_ci_event(id).map_err(QueueError::db)? {
                 #[allow(clippy::single_match)]
                 match qe.event() {
                     CiEvent::V1(CiEventV1::Shutdown) => return Ok(Some(qe.clone())),
                     _ => (),
                 }
                 queue.push(qe);
             }
         }