@@ -38,7 +38,7 @@ impl FlussAdmin {
3838 ) -> PyResult < Bound < ' py , PyAny > > {
3939 let ignore = ignore_if_exists. unwrap_or ( false ) ;
4040
41- let core_table_path = table_path. to_core ( ) . clone ( ) ;
41+ let core_table_path = table_path. to_core ( ) ;
4242 let core_descriptor = table_descriptor. to_core ( ) . clone ( ) ;
4343 let admin = self . __admin . clone ( ) ;
4444
@@ -58,7 +58,7 @@ impl FlussAdmin {
5858 py : Python < ' py > ,
5959 table_path : & TablePath ,
6060 ) -> PyResult < Bound < ' py , PyAny > > {
61- let core_table_path = table_path. to_core ( ) . clone ( ) ;
61+ let core_table_path = table_path. to_core ( ) ;
6262 let admin = self . __admin . clone ( ) ;
6363
6464 future_into_py ( py, async move {
@@ -80,7 +80,7 @@ impl FlussAdmin {
8080 py : Python < ' py > ,
8181 table_path : & TablePath ,
8282 ) -> PyResult < Bound < ' py , PyAny > > {
83- let core_table_path = table_path. to_core ( ) . clone ( ) ;
83+ let core_table_path = table_path. to_core ( ) ;
8484 let admin = self . __admin . clone ( ) ;
8585
8686 future_into_py ( py, async move {
@@ -174,7 +174,7 @@ impl FlussAdmin {
174174 return Err ( FlussError :: new_err ( format ! (
175175 "Invalid offset_type: '{}'. Must be 'earliest', 'latest', or 'timestamp'" ,
176176 offset_type
177- ) ) )
177+ ) ) ) ;
178178 }
179179 } ;
180180
0 commit comments