diff --git a/database/pgsql/lock.go b/database/pgsql/lock.go index 82d1c75f..cbf34e1a 100644 --- a/database/pgsql/lock.go +++ b/database/pgsql/lock.go @@ -32,9 +32,6 @@ func (pgSQL *pgSQL) Lock(name string, owner string, duration time.Duration, rene defer observeQueryTime("Lock", "all", time.Now()) - // Prune locks. - pgSQL.pruneLocks() - // Compute expiration. until := time.Now().Add(duration) @@ -49,6 +46,9 @@ func (pgSQL *pgSQL) Lock(name string, owner string, duration time.Duration, rene // Updated successfully. return true, until } + } else { + // Prune locks. + pgSQL.pruneLocks() } // Lock.