diff --git a/crates/syn2mas/src/migration.rs b/crates/syn2mas/src/migration.rs index 4054dcfdd..07f55e42b 100644 --- a/crates/syn2mas/src/migration.rs +++ b/crates/syn2mas/src/migration.rs @@ -236,7 +236,7 @@ async fn migrate_users( ) -> Result<(MasWriter, MigrationState), Error> { let start = Instant::now(); - let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024); + let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024); let mut rng = rand_chacha::ChaCha8Rng::from_rng(rng).expect("failed to seed rng"); let task = tokio::spawn( @@ -496,7 +496,7 @@ async fn migrate_devices( ) -> Result<(MasWriter, MigrationState), Error> { let start = Instant::now(); - let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024); + let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024); let mut rng = rand_chacha::ChaChaRng::from_rng(rng).expect("failed to seed rng"); let task = tokio::spawn( @@ -619,7 +619,7 @@ async fn migrate_unrefreshable_access_tokens( ) -> Result<(MasWriter, MigrationState), Error> { let start = Instant::now(); - let (tx, mut rx) = tokio::sync::mpsc::channel(1024 * 1024); + let (tx, mut rx) = tokio::sync::mpsc::channel(10 * 1024 * 1024); let now = clock.now(); let mut rng = rand_chacha::ChaChaRng::from_rng(rng).expect("failed to seed rng");