Loader: Fix table name in COPY logs (close #1316)

snowplow · Mar 14, 2024 · 6d76f36 · 6d76f36
1 parent 466994a
commit 6d76f36
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/modules/loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/db/Migration.scala b/modules/loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/db/Migration.scala
@@ -256,7 +256,7 @@ object Migration {
           val inAction = Logging[F].info(s"Creating ${b.getName} table for ${target.getInfo.toSchemaUri}") *>
             in.traverse_(item => DAO[F].executeUpdate(item.statement, DAO.Purpose.NonLoading)) *>
             DAO[F].executeUpdate(b.getCommentOn, DAO.Purpose.NonLoading) *>
-            Logging[F].info("Table created")
+            Logging[F].info(s"Table ${b.getName} created")
           migration.addInTransaction(inAction)
 
         case (migration, b @ Block(Nil, in, _)) =>

diff --git a/modules/loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/db/Statement.scala b/modules/loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/db/Statement.scala
@@ -78,7 +78,7 @@ object Statement {
     tableName: String
   ) extends Statement
       with Loading {
-    def table: String = shreddedType.info.getName
+    def table: String = tableName
     def path: String = shreddedType.getLoadPath
     def title = s"COPY $table FROM $path"
   }