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

snowplow · Nov 9, 2023 · c806229 · c806229
1 parent 79868f8
commit c806229
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
@@ -253,7 +253,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
@@ -75,7 +75,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"
   }