From 077ed5dd04240f86e1aff8178938891d7d70adf8 Mon Sep 17 00:00:00 2001 From: Paolo Di Tommaso Date: Wed, 26 Jul 2023 21:23:00 +0200 Subject: [PATCH] Logging improvements Signed-off-by: Paolo Di Tommaso --- .../groovy/nextflow/processor/TaskPollingMonitor.groovy | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy b/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy index 173579de39..17c2694c46 100644 --- a/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy +++ b/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy @@ -271,7 +271,7 @@ class TaskPollingMonitor implements TaskMonitor { */ @Override TaskMonitor start() { - log.trace ">>> barrier register (monitor: ${this.name})" + log.debug ">>> barrier register (monitor: ${this.name})" session.barrier.register(this) this.taskCompleteLock = new ReentrantLock() @@ -292,8 +292,11 @@ class TaskPollingMonitor implements TaskMonitor { try { pollLoop() } + catch (Throwable e) { + log.debug "Unexpected error in tasks monitor pool loop", e + } finally { - log.trace "<<< barrier arrives (monitor: ${this.name})" + log.debug "<<< barrier arrives (monitor: ${this.name}) - terminating tasks monitor poll loop" session.barrier.arrive(this) } } @@ -434,7 +437,7 @@ class TaskPollingMonitor implements TaskMonitor { try { def pending = runningQueue.size() if( !pending ) { - log.debug "No more task to compute -- ${session.dumpNetworkStatus() ?: 'Execution may be stalled'}" + log.debug "!! executor $name > No more task to compute -- ${session.dumpNetworkStatus() ?: 'Execution may be stalled'}" return }