@@ -58,7 +58,7 @@ pub struct LogEvent {
5858impl LogEvent {
5959 pub fn default_for_verification < RT : Runtime > ( runtime : & RT ) -> anyhow:: Result < Self > {
6060 let mut payload = serde_json:: Map :: new ( ) ;
61- payload. insert ( "message" . to_string ( ) , "Convex connection test" . try_into ( ) ? ) ;
61+ payload. insert ( "message" . to_string ( ) , "Convex connection test" . into ( ) ) ;
6262 Ok ( Self {
6363 topic : LogTopic :: Verification ,
6464 source : EventSource :: System ,
@@ -124,16 +124,16 @@ impl TryFrom<LogEvent> for serde_json::Map<String, JsonValue> {
124124 // Global system fields
125125 fields. insert ( "_topic" . to_string ( ) , event. topic . try_into ( ) ?) ;
126126 let ms = event. timestamp . as_ms_since_epoch ( ) ?;
127- fields. insert ( "_timestamp" . to_string ( ) , ms. try_into ( ) ? ) ;
127+ fields. insert ( "_timestamp" . to_string ( ) , ms. into ( ) ) ;
128128 // Source system fields
129129 match event. source {
130130 EventSource :: Function ( f) => {
131- fields. insert ( "_functionPath" . to_string ( ) , f. path . try_into ( ) ? ) ;
131+ fields. insert ( "_functionPath" . to_string ( ) , f. path . into ( ) ) ;
132132 fields. insert (
133133 "_functionType" . to_string ( ) ,
134134 serde_json:: to_value ( f. udf_type ) ?,
135135 ) ;
136- fields. insert ( "_functionCached" . to_string ( ) , f. cached . try_into ( ) ? ) ;
136+ fields. insert ( "_functionCached" . to_string ( ) , f. cached . into ( ) ) ;
137137 } ,
138138 EventSource :: System => { } ,
139139 }
0 commit comments