去掉错误的日志

ipconfiger · ipconfiger · commit 34f91f716fff · 2024-03-14T11:02:48.000+08:00
diff --git a/src/executor.rs b/src/executor.rs
@@ -596,7 +596,7 @@ fn worker_body(thread_id: usize, rx: Receiver<RowEvents>, mapping: &mut TableMet
                         }
                         let mut message = DmlMessage::from_dml(current_data, &mut meta);
                         let json_str = message.format_json(&mut meta);
-                        info!("will sent:\n{}", &json_str);
+                        //info!("will sent:\n{}", &json_str);
                         if ports.len() > 0 {
                             for (mq_name, topic) in ports {
                                 let msg_qu = QueueMessage { topic, payload: json_str.clone(), pos };

Original file line number	Diff line number	Diff line change
`@@ -596,7 +596,7 @@ fn worker_body(thread_id: usize, rx: Receiver<RowEvents>, mapping: &mut TableMet`
`596`	`596`	`}`
`597`	`597`	`let mut message = DmlMessage::from_dml(current_data, &mut meta);`
`598`	`598`	`let json_str = message.format_json(&mut meta);`
`599`		`- info!("will sent:\n{}", &json_str);`
	`599`	`+ //info!("will sent:\n{}", &json_str);`
`600`	`600`	`if ports.len() > 0 {`
`601`	`601`	`for (mq_name, topic) in ports {`
`602`	`602`	`let msg_qu = QueueMessage { topic, payload: json_str.clone(), pos };`