diff --git a/lib/transaction.js b/lib/transaction.js index 862d9e4f..9ec76055 100644 --- a/lib/transaction.js +++ b/lib/transaction.js @@ -109,9 +109,10 @@ if (Transaction) { cb = cb || utils.createPromiseCallback(); // Report an error if the transaction is not active if (!self.connection) { - return process.nextTick(function() { + process.nextTick(function() { cb(new Error('The transaction is not active: ' + self.id)); }); + return cb.promise; } var context = { transaction: self, @@ -142,9 +143,10 @@ if (Transaction) { cb = cb || utils.createPromiseCallback(); // Report an error if the transaction is not active if (!self.connection) { - return process.nextTick(function() { + process.nextTick(function() { cb(new Error('The transaction is not active: ' + self.id)); }); + return cb.promise; } var context = { transaction: self,