Merge pull request #2271 from Kobzol/sqlite-queue

Allow running the website with SQLite

Author: Kobzol

database/src/pool.rs

@@ -22,6 +22,9 @@ pub trait Connection: Send + Sync {
 
     async fn load_index(&mut self) -> Index;
 
+    /// Returns true if the given database backend supports the job queue system.
+    fn supports_job_queue(&self) -> bool;
+
     /// None means that the caller doesn't know; it should be left alone if
     /// known or set to false if unknown.
     async fn record_compile_benchmark(

database/src/pool/postgres.rs

@@ -2335,6 +2335,10 @@ where
             .await?;
         Ok(())
     }
+
+    fn supports_job_queue(&self) -> bool {
+        true
+    }
 }
 
 fn row_to_benchmark_request(row: &Row, row_offset: Option<usize>) -> BenchmarkRequest {

database/src/pool/sqlite.rs

@@ -1303,7 +1303,9 @@ impl Connection for SqliteConnection {
     }
 
     async fn load_benchmark_request_index(&self) -> anyhow::Result<BenchmarkRequestIndex> {
-        no_queue_implementation_abort!()
+        Ok(BenchmarkRequestIndex {
+            all: Default::default(),
+        })
     }
 
     async fn load_pending_benchmark_requests(&self) -> anyhow::Result<PendingBenchmarkRequests> {
@@ -1438,6 +1440,10 @@ impl Connection for SqliteConnection {
     ) -> anyhow::Result<Vec<BenchmarkRequestWithErrors>> {
         no_queue_implementation_abort!()
     }
+
+    fn supports_job_queue(&self) -> bool {
+        false
+    }
 }
 
 fn parse_artifact_id(ty: &str, sha: &str, date: Option<i64>) -> ArtifactId {

site/src/job_queue/mod.rs

@@ -366,6 +366,9 @@ async fn process_benchmark_requests(
 /// finishes completed benchmark requests.
 async fn perform_queue_tick(ctxt: &SiteCtxt) -> anyhow::Result<()> {
     let mut conn = ctxt.conn().await;
+    if !conn.supports_job_queue() {
+        return Ok(());
+    }
 
     let index = ctxt.known_benchmark_requests.load();