chore(pipeline): append message "while in processor thread" only in TRACE level.
@@ -241,10 +241,16 @@ impl PipelineExecutor {
let try_result = catch_unwind(move || -> Result<()> {
match this_clone.execute_single_thread(thread_num) {
Ok(_) => Ok(()),
- Err(cause) => Err(cause.add_message_back(format!(
+ Err(cause) => {
+ if tracing::enabled!(tracing::Level::TRACE) {
+ Err(cause.add_message_back(format!(
" (while in processor thread {})",
thread_num
- ))),
+ )))
+ } else {
+ Err(cause)
+ }
+ }
}
});
