diff --git a/crates/application/src/worker.rs b/crates/application/src/worker.rs index 73602a3..b30dc81 100644 --- a/crates/application/src/worker.rs +++ b/crates/application/src/worker.rs @@ -7,7 +7,7 @@ use domain::{ use futures::StreamExt; use tokio::sync::Semaphore; -const DEFAULT_CONCURRENCY: usize = 8; +const DEFAULT_CONCURRENCY: usize = 4; pub struct WorkerService { consumer: Arc,