update concurrency limit

modrinth · Jun 25, 2024 · c4b0927 · c4b0927
1 parent ed16d2d
commit c4b0927
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/.env b/.env
@@ -2,6 +2,8 @@ RUST_LOG=warn,daedalus_client=trace
 
 BASE_URL=http://localhost:9000/meta
 
+CONCURRENCY_LIMIT=10
+
 S3_ACCESS_TOKEN=none
 S3_SECRET=none
 S3_URL=http://localhost:9000

diff --git a/daedalus_client/src/main.rs b/daedalus_client/src/main.rs
@@ -36,7 +36,12 @@ async fn main() -> Result<()> {
         return Ok(());
     }
 
-    let semaphore = Arc::new(Semaphore::new(1));
+    let semaphore = Arc::new(Semaphore::new(
+        dotenvy::var("CONCURRENCY_LIMIT")
+            .ok()
+            .and_then(|x| x.parse().ok())
+            .unwrap_or(10),
+    ));
 
     // path, upload file
     let upload_files: DashMap<String, UploadFile> = DashMap::new();