Simplify error handling in PartitionedDataFrameStreamReader

Author: kosiew

python/tests/test_dataframe.py

@@ -3353,9 +3353,6 @@ def read_stream():
     interrupt_thread.join(timeout=1.0)
 
 
-
-
-
 def test_show_select_where_no_rows(capsys) -> None:
     ctx = SessionContext()
     df = ctx.sql("SELECT 1 WHERE 1=0")

src/dataframe.rs

@@ -389,9 +389,7 @@ impl Iterator for PartitionedDataFrameStreamReader {
                     let batch = if let Some(ref schema) = self.projection {
                         match record_batch_into_schema(batch, schema.as_ref()) {
                             Ok(b) => b,
-                            Err(e) => {
-                                return Some(Err(e));
-                            }
+                            Err(e) => return Some(Err(e)),
                         }
                     } else {
                         batch