diff --git a/packages/pg-pool/index.js b/packages/pg-pool/index.js index 46d2aab0..0d7314eb 100644 --- a/packages/pg-pool/index.js +++ b/packages/pg-pool/index.js @@ -255,9 +255,14 @@ class Pool extends EventEmitter { setTimeout(() => { this.log('ending client due to expired lifetime') this._expired.add(client) - const idleIndex = this._idle.findIndex(idleItem => idleItem.client === client) + const idleIndex = this._idle.findIndex((idleItem) => idleItem.client === client) if (idleIndex !== -1) { - this._acquireClient(client, new PendingItem((err, client, clientRelease) => clientRelease()), idleListener, false) + this._acquireClient( + client, + new PendingItem((err, client, clientRelease) => clientRelease()), + idleListener, + false + ) } }, this.options.maxLifetimeSeconds * 1000) } diff --git a/packages/pg-pool/test/lifetime-timeout.js b/packages/pg-pool/test/lifetime-timeout.js index 98616162..fddd5ff0 100644 --- a/packages/pg-pool/test/lifetime-timeout.js +++ b/packages/pg-pool/test/lifetime-timeout.js @@ -29,7 +29,8 @@ describe('lifetime timeout', () => { done() }) }) - it('can remove expired clients and recreate them', + it( + 'can remove expired clients and recreate them', co.wrap(function* () { const pool = new Pool({ maxLifetimeSeconds: 1 }) let query = pool.query('SELECT pg_sleep(1)')