refactor: coderabbit suggestion

Author: Devdutt Shenoi

src/storage/mod.rs

@@ -16,6 +16,7 @@
  *
  */
 
+use arrow_schema::ArrowError;
 use object_store::path::Path;
 use relative_path::RelativePath;
 use serde::{Deserialize, Serialize};
@@ -261,6 +262,9 @@ pub enum ObjectStorageError {
 
     #[error("JoinError: {0}")]
     JoinError(#[from] JoinError),
+
+    #[error("ArrowError: {0}")]
+    Arrow(#[from] ArrowError),
 }
 
 pub fn to_object_store_path(path: &RelativePath) -> Path {

src/storage/object_storage.rs

@@ -877,7 +877,7 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
         schema: Schema,
     ) -> Result<(), ObjectStorageError> {
         let stream_schema = self.get_schema(stream_name).await?;
-        let new_schema = Schema::try_merge(vec![schema, stream_schema]).unwrap();
+        let new_schema = Schema::try_merge(vec![schema, stream_schema])?;
         self.put_schema(stream_name, &new_schema).await
     }