Skip to content

Commit

Permalink
Remove redundant exception handling [ci fast]
Browse files Browse the repository at this point in the history
Signed-off-by: Paolo Di Tommaso <[email protected]>
  • Loading branch information
pditommaso committed Jan 23, 2025
1 parent 9031968 commit 00376aa
Showing 1 changed file with 2 additions and 13 deletions.
15 changes: 2 additions & 13 deletions modules/nextflow/src/main/groovy/nextflow/Session.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -16,14 +16,12 @@

package nextflow


import java.nio.file.Files
import java.nio.file.Path
import java.nio.file.Paths
import java.util.concurrent.ConcurrentLinkedQueue
import java.util.concurrent.ExecutorService
import java.util.concurrent.Executors
import java.util.concurrent.TimeoutException

import com.google.common.hash.HashCode
import groovy.transform.CompileDynamic
Expand Down Expand Up @@ -690,17 +688,8 @@ class Session implements ISession {
try {
log.trace "Session > destroying"
// shutdown thread pools
try {
finalizePoolManager?.shutdownOrAbort(aborted,this)
publishPoolManager?.shutdownOrAbort(aborted,this)
}
catch( TimeoutException e ) {
final ignoreErrors = config.navigate('workflow.output.ignoreErrors', false)
if( !ignoreErrors )
throw new AbortOperationException("Timed out while waiting to publish outputs")
else
log.warn e.message
}
finalizePoolManager?.shutdownOrAbort(aborted,this)
publishPoolManager?.shutdownOrAbort(aborted,this)
// invoke shutdown callbacks
shutdown0()
log.trace "Session > after cleanup"
Expand Down

0 comments on commit 00376aa

Please sign in to comment.