WIP

internal/datastore/postgres/locks.go

@@ -2,6 +2,7 @@ package postgres
 
 import (
 	"context"
+	"fmt"
 )
 
 type lockID uint32
@@ -19,15 +20,18 @@ func (pgd *pgDatastore) tryAcquireLock(ctx context.Context, lockID lockID) (bool
 
 	var lockAcquired bool
 	if err := row.Scan(&lockAcquired); err != nil {
+		fmt.Printf("Error acquiring lock: %v\n", err)
 		return false, err
 	}
 
+	fmt.Printf("Lock acquired: %v\n", lockAcquired)
 	return lockAcquired, nil
 }
 
 func (pgd *pgDatastore) releaseLock(ctx context.Context, lockID lockID) error {
 	_, err := pgd.writePool.Exec(ctx, `
 		SELECT pg_advisory_unlock($1)
 	`, lockID)
+	fmt.Printf("Lock released: %v\n", err)
 	return err
 }