Refactor signal checking in future collection to simplify error handling

Author: kosiew

src/utils.rs

@@ -28,7 +28,6 @@ use datafusion_ffi::table_provider::{FFI_TableProvider, ForeignTableProvider};
 use pyo3::exceptions::PyValueError;
 use pyo3::prelude::*;
 use pyo3::types::PyCapsule;
-use pyo3::PyErr;
 use tokio::runtime::Runtime;
 use tokio::task::JoinHandle;
 use tokio::time::sleep;
@@ -87,13 +86,9 @@ where
                     res = &mut fut => break Ok(res),
                     _ = sleep(INTERVAL_CHECK_SIGNALS) => {
                         Python::attach(|py| {
-                            if let Some(err) = PyErr::take(py) {
-                                Err(err)
-                            } else {
                                 let code = CString::new("pass").unwrap();
                                 py.run(code.as_c_str(), None, None)?;
                                 py.check_signals()
-                            }
                         })?;
                     }
                 }