fix(coprocessor): semaphore panic possibility reported by Claude

rudy-6-4 · rudy-6-4 · commit e925694e7e14 · 2026-02-06T17:56:15.000+01:00
diff --git a/coprocessor/fhevm-engine/sns-worker/src/aws_upload.rs b/coprocessor/fhevm-engine/sns-worker/src/aws_upload.rs
@@ -165,7 +165,7 @@ async fn run_uploader_loop(
                 }
 
                 // Acquire a permit for an upload
-                let permit = semaphore.clone().acquire_owned().await.expect("Failed to acquire semaphore permit");
+                let permit = semaphore.clone().acquire_owned().await.map_err(|err| ExecutionError::InternalError(err.to_string()))?;
                 let client = client.clone();
                 let conf = conf.clone();
                 let ready_flag = is_ready.clone();

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ async fn run_uploader_loop(`
`165`	`165`	`}`
`166`	`166`
`167`	`167`	`// Acquire a permit for an upload`
`168`		`- let permit = semaphore.clone().acquire_owned().await.expect("Failed to acquire semaphore permit");`
	`168`	`+ let permit = semaphore.clone().acquire_owned().await.map_err(\|err\| ExecutionError::InternalError(err.to_string()))?;`
`169`	`169`	`let client = client.clone();`
`170`	`170`	`let conf = conf.clone();`
`171`	`171`	`let ready_flag = is_ready.clone();`