@@ -74,13 +74,13 @@ impl<'py> IntoPyObject<'py> for Value {
7474 }
7575 databend_driver:: Value :: Timestamp ( _) => {
7676 let t = NaiveDateTime :: try_from ( self . 0 ) . map_err ( |e| {
77- PyException :: new_err ( format ! ( "failed to convert timestamp: {}" , e ) )
77+ PyException :: new_err ( format ! ( "failed to convert timestamp: {e}" ) )
7878 } ) ?;
7979 t. into_bound_py_any ( py) ?
8080 }
8181 databend_driver:: Value :: Date ( _) => {
8282 let d = NaiveDate :: try_from ( self . 0 )
83- . map_err ( |e| PyException :: new_err ( format ! ( "failed to convert date: {}" , e ) ) ) ?;
83+ . map_err ( |e| PyException :: new_err ( format ! ( "failed to convert date: {e}" ) ) ) ?;
8484 d. into_bound_py_any ( py) ?
8585 }
8686 databend_driver:: Value :: Array ( inner) => {
@@ -208,9 +208,7 @@ impl Row {
208208 . fields ( )
209209 . iter ( )
210210 . position ( |f| f. name == field)
211- . ok_or_else ( || {
212- PyException :: new_err ( format ! ( "field '{}' not found in schema" , field) )
213- } ) ?;
211+ . ok_or_else ( || PyException :: new_err ( format ! ( "field '{field}' not found in schema" ) ) ) ?;
214212 Ok ( Value ( self . inner . values ( ) [ idx] . clone ( ) ) )
215213 }
216214
@@ -252,7 +250,7 @@ impl RowIterator {
252250 wait_for_future ( py, async move {
253251 match streamer. lock ( ) . await . next ( ) . await {
254252 Some ( val) => match val {
255- Err ( e) => Err ( PyException :: new_err ( format ! ( "{}" , e ) ) ) ,
253+ Err ( e) => Err ( PyException :: new_err ( format ! ( "{e}" ) ) ) ,
256254 Ok ( ret) => Ok ( Row :: new ( ret) ) ,
257255 } ,
258256 None => Err ( PyStopIteration :: new_err ( "Rows exhausted" ) ) ,
@@ -268,7 +266,7 @@ impl RowIterator {
268266 future_into_py ( py, async move {
269267 match streamer. lock ( ) . await . next ( ) . await {
270268 Some ( val) => match val {
271- Err ( e) => Err ( PyException :: new_err ( format ! ( "{}" , e ) ) ) ,
269+ Err ( e) => Err ( PyException :: new_err ( format ! ( "{e}" ) ) ) ,
272270 Ok ( ret) => Ok ( Row :: new ( ret) ) ,
273271 } ,
274272 None => Err ( PyStopAsyncIteration :: new_err ( "The iterator is exhausted" ) ) ,
0 commit comments