Update executor_worker_context.rs
@@ -80,6 +80,7 @@ impl ExecutorWorkerContext {
}
unsafe fn execute_sync_task(&mut self, processor: ProcessorPtr) -> Result<Option<NodeIndex>> {
+ if tracing::enabled!(tracing::Level::DEBUG) {
let start = Instant::now();
processor.process()?;
tracing::debug!(
@@ -88,6 +89,10 @@ impl ExecutorWorkerContext {
processor.name(),
start.elapsed()
);
+ } else {
+ processor.process()?;
+ }
+
Ok(Some(processor.id()))
}
