Skip to content

Commit fdea36d

Browse files
committed
Fix pool.begin() doesn't begin transaction
1 parent a4ee3e9 commit fdea36d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tornado_mysql/pools.py

+1
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,7 @@ def begin(self):
111111
:rtype: Future
112112
"""
113113
conn = yield self._get_conn()
114+
yield conn.begin()
114115
trx = Transaction(self, conn)
115116
raise Return(trx)
116117

0 commit comments

Comments
 (0)