@@ -11,7 +11,7 @@ use tokio::time::{self, Duration};
1111/// already in the database
1212async fn enqueue_master_commits (
1313 ctxt : & Arc < SiteCtxt > ,
14- conn : & Box < dyn database:: pool:: Connection > ,
14+ conn : & dyn database:: pool:: Connection ,
1515) -> anyhow:: Result < ( ) > {
1616 let master_commits = & ctxt. get_master_commits ( ) . commits ;
1717 // TODO; delete at some point in the future
@@ -94,7 +94,7 @@ fn get_next_benchmark_request<'a>(
9494}
9595
9696/// Enqueue the job into the job_queue
97- async fn enqueue_next_job ( conn : & mut Box < dyn database:: pool:: Connection > ) -> anyhow:: Result < ( ) > {
97+ async fn enqueue_next_job ( conn : & mut dyn database:: pool:: Connection ) -> anyhow:: Result < ( ) > {
9898 let mut pending = conn
9999 . get_benchmark_requests_by_status (
100100 & [
@@ -125,7 +125,7 @@ async fn enqueue_next_job(conn: &mut Box<dyn database::pool::Connection>) -> any
125125 if let Some ( next_request) = get_next_benchmark_request ( & mut pending, & mut completed_set) {
126126 // TODO; we simply flip the status for now however this should also
127127 // create the relevant jobs in the `job_queue`
128- conn. update_benchmark_request_status ( & next_request, BenchmarkRequestStatus :: InProgress )
128+ conn. update_benchmark_request_status ( next_request, BenchmarkRequestStatus :: InProgress )
129129 . await ?
130130 }
131131
@@ -136,8 +136,8 @@ async fn enqueue_next_job(conn: &mut Box<dyn database::pool::Connection>) -> any
136136async fn cron_enqueue_jobs ( site_ctxt : & Arc < SiteCtxt > ) -> anyhow:: Result < ( ) > {
137137 let mut conn = site_ctxt. conn ( ) . await ;
138138 // Put the master commits into the `benchmark_requests` queue
139- enqueue_master_commits ( site_ctxt, & conn) . await ?;
140- enqueue_next_job ( & mut conn) . await ?;
139+ enqueue_master_commits ( site_ctxt, & * conn) . await ?;
140+ enqueue_next_job ( & mut * conn) . await ?;
141141 Ok ( ( ) )
142142}
143143
0 commit comments