From 5e8bb6309762721a91f8632c2556e27b0cd250ee Mon Sep 17 00:00:00 2001
From: Thanh Le <lenguyenthanh@hotmail.com>
Date: Mon, 23 Dec 2024 08:19:23 +0700
Subject: [PATCH] Better logger name for ingestor

---
 modules/ingestor/src/main/scala/ingestor.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/modules/ingestor/src/main/scala/ingestor.scala b/modules/ingestor/src/main/scala/ingestor.scala
index 9a04648..319786f 100644
--- a/modules/ingestor/src/main/scala/ingestor.scala
+++ b/modules/ingestor/src/main/scala/ingestor.scala
@@ -31,7 +31,7 @@ object Ingestor:
       elastic: ESClient[IO],
       defaultStartAt: Option[Instant]
   )(using LoggerFactory[IO]): Ingestor = new:
-    given Logger[IO] = LoggerFactory[IO].getLogger
+    given Logger[IO] = LoggerFactory[IO].getLoggerFromName(s"${index.value}.ingestor")
 
     def watch: IO[Unit] =
       fs2.Stream