diff --git a/src/transaction.js b/src/transaction.js index 8d957bad..c9c65f92 100644 --- a/src/transaction.js +++ b/src/transaction.js @@ -46,10 +46,10 @@ function Transaction(client, container, config, outerTx) { } if (result && result.then && typeof result.then === 'function') { result.then((val) => { - transactor.commit(val) + return transactor.commit(val) }) .catch((err) => { - transactor.rollback(err) + return transactor.rollback(err) }) } return null;