Introduce a delay between scheduled jobs (#273)

Signed-off-by: Sergio Castaño Arteaga <[email protected]>
cncf · Oct 25, 2024 · ed523cf · ed523cf
1 parent 5a88065
commit ed523cf
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/clowarden-server/src/jobs.rs b/clowarden-server/src/jobs.rs
@@ -20,11 +20,11 @@ use clowarden_core::{
 use futures::future::{self, JoinAll};
 use octorust::types::{ChecksCreateRequestConclusion, JobStatus, PullRequestData};
 use serde::{Deserialize, Serialize};
-use std::{collections::HashMap, sync::Arc};
+use std::{collections::HashMap, sync::Arc, time::Duration};
 use tokio::{
     sync::{broadcast, mpsc},
     task::JoinHandle,
-    time::{self, MissedTickBehavior},
+    time::{self, sleep, MissedTickBehavior},
 };
 use tracing::{debug, error, instrument};
 
@@ -377,6 +377,9 @@ pub(crate) fn scheduler(
                             org: org.clone(),
                             ..Default::default()
                         }));
+
+                        // Introduce a delay between scheduled jobs
+                        sleep(Duration::from_secs(30)).await;
                     }
                 },
             }