Skip to content

Commit 9ae9e13

Browse files
authored
Replace unwrap (#183)
1 parent 9768b0e commit 9ae9e13

File tree

4 files changed

+12
-12
lines changed

4 files changed

+12
-12
lines changed

crates/iceberg/src/spec/manifest.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -661,7 +661,7 @@ mod _const_schema {
661661
])),
662662
)),
663663
];
664-
let schema = Schema::builder().with_fields(fields).build().unwrap();
664+
let schema = Schema::builder().with_fields(fields).build()?;
665665
schema_to_avro_schema("manifest", &schema)
666666
}
667667

crates/iceberg/src/spec/manifest_list.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -215,8 +215,8 @@ impl ManifestListWriter {
215215
pub async fn close(self) -> Result<()> {
216216
let data = self.avro_writer.into_inner()?;
217217
let mut writer = self.output_file.writer().await?;
218-
writer.write_all(&data).await.unwrap();
219-
writer.close().await.unwrap();
218+
writer.write_all(&data).await?;
219+
writer.close().await?;
220220
Ok(())
221221
}
222222
}

crates/iceberg/src/spec/table_metadata.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -687,7 +687,7 @@ pub(super) mod _serde {
687687
schema: v
688688
.schemas
689689
.get(&v.current_schema_id)
690-
.unwrap()
690+
.expect("current_schema_id not found in schemas")
691691
.as_ref()
692692
.clone()
693693
.into(),
@@ -867,12 +867,12 @@ mod tests {
867867
{
868868
"spec-id": 1,
869869
"fields": [
870-
{
871-
"source-id": 4,
872-
"field-id": 1000,
873-
"name": "ts_day",
870+
{
871+
"source-id": 4,
872+
"field-id": 1000,
873+
"name": "ts_day",
874874
"transform": "day"
875-
}
875+
}
876876
]
877877
}
878878
],
@@ -882,8 +882,8 @@ mod tests {
882882
"commit.retry.num-retries": "1"
883883
},
884884
"metadata-log": [
885-
{
886-
"metadata-file": "s3://bucket/.../v1.json",
885+
{
886+
"metadata-file": "s3://bucket/.../v1.json",
887887
"timestamp-ms": 1515100
888888
}
889889
],

crates/iceberg/src/transaction.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ impl<'a> ReplaceSortOrderAction<'a> {
160160
.table
161161
.metadata()
162162
.default_sort_order()
163-
.unwrap()
163+
.expect("default sort order impossible to be None")
164164
.order_id,
165165
},
166166
];

0 commit comments

Comments
 (0)