Skip to content

Commit 7650fe3

Browse files
committed
worker/tests: Extract pool() fn
1 parent 09191e7 commit 7650fe3

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

crates/crates_io_worker/tests/runner.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -317,12 +317,16 @@ async fn jobs_can_be_deduplicated() {
317317
runner.wait_for_shutdown().await;
318318
}
319319

320+
fn pool(database_url: &str) -> Pool<AsyncPgConnection> {
321+
let manager = AsyncDieselConnectionManager::<AsyncPgConnection>::new(database_url);
322+
Pool::builder(manager).max_size(4).build().unwrap()
323+
}
324+
320325
fn runner<Context: Clone + Send + Sync + 'static>(
321326
database_url: &str,
322327
context: Context,
323328
) -> Runner<Context> {
324-
let manager = AsyncDieselConnectionManager::<AsyncPgConnection>::new(database_url);
325-
let deadpool = Pool::builder(manager).max_size(4).build().unwrap();
329+
let deadpool = pool(database_url);
326330

327331
Runner::new(deadpool, context)
328332
.configure_default_queue(|queue| queue.num_workers(2))

0 commit comments

Comments
 (0)