diff --git a/plugins/nf-tower/src/main/io/seqera/tower/plugin/TowerClient.groovy b/plugins/nf-tower/src/main/io/seqera/tower/plugin/TowerClient.groovy index e9cc657766..8e23482c25 100644 --- a/plugins/nf-tower/src/main/io/seqera/tower/plugin/TowerClient.groovy +++ b/plugins/nf-tower/src/main/io/seqera/tower/plugin/TowerClient.groovy @@ -46,6 +46,7 @@ import nextflow.trace.TraceObserver import nextflow.trace.TraceRecord import nextflow.util.Duration import nextflow.util.LoggerHelper +import nextflow.util.PathTrie import nextflow.util.ProcessHelper import nextflow.util.SimpleHttpClient import nextflow.util.TestOnly @@ -70,6 +71,8 @@ class TowerClient implements TraceObserver { static private final String TOKEN_PREFIX = '@token:' + final PathTrie trie = new PathTrie() + @TupleConstructor static class Response { final int code @@ -408,6 +411,7 @@ class TowerClient implements TraceObserver { final req = makeCompleteReq(session) final resp = sendHttpMessage(urlTraceComplete, req, 'PUT') logHttpResponse(urlTraceComplete, resp) + log.info "Output dir=${trie.longest()}" } @Override @@ -487,6 +491,7 @@ class TowerClient implements TraceObserver { @Override void onFilePublish(Path destination) { reports.filePublish(destination) + trie.add(destination) } protected void refreshToken(String refresh) {