User self.release() method to release a connection while releasing a …

…cursor
05bit · May 6, 2016 · ee93457 · ee93457
1 parent e4617ed
commit ee93457
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/peewee_async.py b/peewee_async.py
@@ -1011,7 +1011,7 @@ def release_cursor(self, cursor, in_transaction=False):
         conn = cursor.connection
         cursor.close()
         if not in_transaction:
-            self.pool.release(conn)
+            self.release(conn)
 
 
 class AsyncPostgresqlMixin(AsyncDatabase):
@@ -1170,7 +1170,7 @@ def release_cursor(self, cursor, in_transaction=False):
         conn = cursor.connection
         yield from cursor.close()
         if not in_transaction:
-            self.pool.release(conn)
+            self.release(conn)
 
 
 class MySQLDatabase(AsyncDatabase, peewee.MySQLDatabase):