WIP.

migration_runner.go

@@ -6,6 +6,7 @@ import (
 	"slices"
 	"time"
 
+	"github.com/go-nacelle/log/v2"
 	"github.com/go-nacelle/nacelle/v2"
 	"github.com/jackc/pgconn"
 )
@@ -17,7 +18,7 @@ type Runner struct {
 	locker      *TransactionalLocker
 }
 
-// TODO - log more/better
+// TODO - additional logging
 
 func NewMigrationRunner(db DB, reader MigrationReader, logger nacelle.Logger) (*Runner, error) {
 	definitions, err := ReadMigrations(reader)
@@ -116,10 +117,6 @@ func (r *Runner) applyDefinitions(ctx context.Context, definitions []Definition,
 			return err
 		}
 
-		//
-		// TODO - need to store hash as well?
-		//
-
 		applied := map[int]struct{}{}
 		for _, log := range migrationLogs {
 			if log.Success != nil && *log.Success && !log.Reverse {
@@ -279,7 +276,9 @@ func (r *Runner) createIndexConcurrently(ctx context.Context, definition Definit
 				`, Args{
 					"id": id,
 				})); err != nil {
-					r.logger.Error("Failed to update heartbeat") // TODO - more information
+					r.logger.ErrorWithFields(log.LogFields{
+						"error": err,
+					}, "Failed to update heartbeat")
 				}
 
 				if err := wait(ctx, time.Second*5); err != nil {