From b77461d88c19d067bb51df8c0ea58ed6e4858370 Mon Sep 17 00:00:00 2001 From: Robert Kenny Date: Fri, 15 Nov 2024 14:37:10 +0000 Subject: [PATCH] reinstate info logs in path processor (#2765) --- .../main/scala/weco/pipeline/batcher/PathsProcessor.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pipeline/relation_embedder/batcher/src/main/scala/weco/pipeline/batcher/PathsProcessor.scala b/pipeline/relation_embedder/batcher/src/main/scala/weco/pipeline/batcher/PathsProcessor.scala index 403f9d6975..b1bf107cec 100644 --- a/pipeline/relation_embedder/batcher/src/main/scala/weco/pipeline/batcher/PathsProcessor.scala +++ b/pipeline/relation_embedder/batcher/src/main/scala/weco/pipeline/batcher/PathsProcessor.scala @@ -53,19 +53,19 @@ object PathsProcessor extends Logging { ): Source[(Batch, List[Long]), NotUsed] = { val selectors = Selector.forPaths(paths) val groupedSelectors = selectors.groupBy(_._1.rootPath) - debug( + info( s"Generated ${selectors.size} selectors spanning ${groupedSelectors.size} trees from ${paths.size} paths." ) paths.sorted.grouped(1000).toList.zipWithIndex.foreach { case (paths, idx) => val startIdx = idx * 1000 + 1 - debug( + info( s"Input paths ($startIdx-${startIdx + paths.length - 1}): ${paths.mkString(", ")}" ) } groupedSelectors.foreach { case (rootPath, selectors) => - debug( + info( s"Selectors for root path $rootPath: ${selectors.map(_._1).mkString(", ")}" ) }