From 4e7970de00361ebc8249ab2f194f059ebe4f1f18 Mon Sep 17 00:00:00 2001
From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com>
Date: Mon, 29 Dec 2025 12:44:51 +0000
Subject: [PATCH 1/2] Initial plan


From 2acab0dd80aa1f973f3af6bcafa4aa6cc3fd828f Mon Sep 17 00:00:00 2001
From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com>
Date: Mon, 29 Dec 2025 13:03:32 +0000
Subject: [PATCH 2/2] Restore 'ETL Pipeline completed successfully' log message

Co-authored-by: akreit <64101884+akreit@users.noreply.github.com>
---
 src/main/scala/com/async2databricks/etl/EtlPipeline.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/scala/com/async2databricks/etl/EtlPipeline.scala b/src/main/scala/com/async2databricks/etl/EtlPipeline.scala
index c93f2c3..c7b57fe 100644
--- a/src/main/scala/com/async2databricks/etl/EtlPipeline.scala
+++ b/src/main/scala/com/async2databricks/etl/EtlPipeline.scala
@@ -40,6 +40,7 @@ class EtlPipeline[F[_]: Async](config: AppConfig) extends CatsLogger {
             )
             // Write to S3
             _ <- s3Writer.writeParquet(dataStream, outputPath)
+            _ <- logger[F].info("ETL Pipeline completed successfully")
           } yield ()
         }
         .handleErrorWith { error =>