diff --git a/cmd/root.go b/cmd/root.go
index 545652a7a9e938e2b7a2598e253287146b98f543..8777acb823229ad82eed591fa1206fcab9ccc27c 100644
--- a/cmd/root.go
+++ b/cmd/root.go
@@ -182,7 +182,7 @@ func setupSubscriber[T any](
 			select {
 			case event, ok := <-subCh:
 				if !ok {
-					logging.Info("%s subscription channel closed", name)
+					logging.Info("subscription channel closed", "name", name)
 					return
 				}
 
@@ -191,13 +191,13 @@ func setupSubscriber[T any](
 				select {
 				case outputCh <- msg:
 				case <-time.After(2 * time.Second):
-					logging.Warn("%s message dropped due to slow consumer", name)
+					logging.Warn("message dropped due to slow consumer", "name", name)
 				case <-ctx.Done():
-					logging.Info("%s subscription cancelled", name)
+					logging.Info("subscription cancelled", "name", name)
 					return
 				}
 			case <-ctx.Done():
-				logging.Info("%s subscription cancelled", name)
+				logging.Info("subscription cancelled", "name", name)
 				return
 			}
 		}
diff --git a/internal/db/connect.go b/internal/db/connect.go
index e850bc8d02a4e9c685e1e5dc71260eacb44a0563..9335bfc263c288f4ca95cffb3bb212a99b0bcec5 100644
--- a/internal/db/connect.go
+++ b/internal/db/connect.go
@@ -48,9 +48,9 @@ func Connect() (*sql.DB, error) {
 
 	for _, pragma := range pragmas {
 		if _, err = db.Exec(pragma); err != nil {
-			logging.Warn("Failed to set pragma", pragma, err)
+			logging.Error("Failed to set pragma", pragma, err)
 		} else {
-			logging.Warn("Set pragma", "pragma", pragma)
+			logging.Debug("Set pragma", "pragma", pragma)
 		}
 	}