diff --git a/src/catalog.rs b/src/catalog.rs index ba7e2225..49fe1404 100644 --- a/src/catalog.rs +++ b/src/catalog.rs @@ -97,7 +97,7 @@ impl PyDatabase { } fn table(&self, name: &str, py: Python) -> PyResult { - if let Some(table) = wait_for_future(py, self.database.table(name)) { + if let Some(table) = wait_for_future(py, self.database.table(name))? { Ok(PyTable::new(table)) } else { Err(DataFusionError::Common(format!("Table not found: {name}")).into())