@@ -7,7 +7,8 @@ use std::sync::Arc;
77use std:: time:: Duration ;
88
99use super :: instrumentation:: CallTimes ;
10- use crate :: database_logger:: { self , SystemLogger } ;
10+ // use crate::database_logger;
11+ use crate :: database_logger:: SystemLogger ;
1112use crate :: db:: datastore:: locking_tx_datastore:: MutTxId ;
1213use crate :: db:: datastore:: traits:: { IsolationLevel , Program } ;
1314use crate :: db:: db_metrics:: DB_METRICS ;
@@ -460,19 +461,19 @@ impl<T: WasmInstance> WasmModuleInstance<T> {
460461 }
461462 }
462463 Ok ( Err ( errmsg) ) => {
463- log:: info!( "reducer returned error: {errmsg}" ) ;
464-
465- self . replica_context ( ) . logger . write (
466- database_logger:: LogLevel :: Error ,
467- & database_logger:: Record {
468- ts : chrono:: DateTime :: from_timestamp_micros ( timestamp. to_micros_since_unix_epoch ( ) ) . unwrap ( ) ,
469- target : Some ( reducer_name) ,
470- filename : None ,
471- line_number : None ,
472- message : & errmsg,
473- } ,
474- & ( ) ,
475- ) ;
464+ // log::info!("reducer returned error: {errmsg}");
465+
466+ // self.replica_context().logger.write(
467+ // database_logger::LogLevel::Error,
468+ // &database_logger::Record {
469+ // ts: chrono::DateTime::from_timestamp_micros(timestamp.to_micros_since_unix_epoch()).unwrap(),
470+ // target: Some(reducer_name),
471+ // filename: None,
472+ // line_number: None,
473+ // message: &errmsg,
474+ // },
475+ // &(),
476+ // );
476477 EventStatus :: Failed ( errmsg. into ( ) )
477478 }
478479 // We haven't actually committed yet - `commit_and_broadcast_event` will commit
0 commit comments