(arrow-datafusion) branch main updated: Error handling. (#8761)

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


The following commit(s) were added to refs/heads/main by this push:
     new 821db545be Error handling. (#8761)
821db545be is described below

commit 821db545be48b39d8522310bf08bc4b0bb28d4bf
Author: Metehan Yıldırım <10...@users.noreply.github.com>
AuthorDate: Sat Jan 6 00:17:04 2024 +0300

    Error handling. (#8761)
---
 datafusion-cli/src/print_options.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/datafusion-cli/src/print_options.rs b/datafusion-cli/src/print_options.rs
index b8594352b5..b382eb34f6 100644
--- a/datafusion-cli/src/print_options.rs
+++ b/datafusion-cli/src/print_options.rs
@@ -141,7 +141,8 @@ impl PrintOptions {
         let mut row_count = 0_usize;
         let mut with_header = true;
 
-        while let Some(Ok(batch)) = stream.next().await {
+        while let Some(maybe_batch) = stream.next().await {
+            let batch = maybe_batch?;
             row_count += batch.num_rows();
             self.format.print_batches(
                 &mut writer,