Err rather than panic failing to create queues_dir_path (#5079)

quickwit-oss · Jun 5, 2024 · b57eb12 · b57eb12
1 parent cc921f7
commit b57eb12
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/quickwit/quickwit-ingest/src/queue.rs b/quickwit/quickwit-ingest/src/queue.rs
@@ -41,7 +41,15 @@ pub struct Queues {
 
 impl Queues {
     pub async fn open(queues_dir_path: &Path) -> crate::Result<Queues> {
-        tokio::fs::create_dir_all(queues_dir_path).await.unwrap();
+        tokio::fs::create_dir_all(queues_dir_path)
+            .await
+            .map_err(|error| {
+                IngestServiceError::IoError(format!(
+                    "failed to create WAL directory `{}`: {}",
+                    queues_dir_path.display(),
+                    error
+                ))
+            })?;
         let record_log = MultiRecordLogAsync::open(queues_dir_path).await?;
         Ok(Queues { record_log })
     }