File tree Expand file tree Collapse file tree
ballista/core/src/remote_catalog Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -42,15 +42,13 @@ impl CatalogSerializeExt for SessionContext {
4242 let catalog_names = self . state ( ) . catalog_list ( ) . catalog_names ( ) ;
4343
4444 stream:: iter ( catalog_names. iter ( ) )
45- . filter_map ( |catalog_name| self . serialize_catalog ( & catalog_name) )
45+ . filter_map ( |catalog_name| self . serialize_catalog ( catalog_name) )
4646 . collect :: < Vec < _ > > ( )
4747 . await
4848 }
4949
5050 async fn serialize_catalog ( & self , name : & str ) -> Option < CatalogInfo > {
51- let Some ( catalog) = self . catalog ( name) else {
52- return None ;
53- } ;
51+ let catalog = self . catalog ( name) ?;
5452
5553 let schemas = stream:: iter ( catalog. schema_names ( ) . iter ( ) )
5654 . filter_map ( |schema_name| self . serialize_schema ( schema_name, & catalog) )
@@ -68,9 +66,7 @@ impl CatalogSerializeExt for SessionContext {
6866 name : & str ,
6967 catalog : & Arc < dyn CatalogProvider > ,
7068 ) -> Option < SchemaInfo > {
71- let Some ( schema) = catalog. schema ( name) else {
72- return None ;
73- } ;
69+ let schema = catalog. schema ( name) ?;
7470
7571 let tables = stream:: iter ( schema. table_names ( ) )
7672 . filter_map ( |table_name| async {
You can’t perform that action at this time.
0 commit comments