diff --git a/lib/pool.js b/lib/pool.js index 7b48b5b97a3..0b0b9eb1033 100644 --- a/lib/pool.js +++ b/lib/pool.js @@ -174,7 +174,7 @@ class Pool extends EventEmitter { this[kPending]++ } else { client.dispatch(opts, handler) - if (this.busy) { + if (client.busy && this.busy) { this[kNeedDrain] = true } }