We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6c0880f commit 120b0c3Copy full SHA for 120b0c3
peewee_async.py
@@ -24,8 +24,6 @@
24
logger = logging.getLogger('peewee.async')
25
logger.addHandler(logging.NullHandler())
26
27
-PEEWEE_VERSION = tuple([int(x) for x in peewee.__version__.split('.')])
28
-
29
try:
30
import aiopg
31
except ImportError:
@@ -1484,10 +1482,10 @@ def _get_exception_wrapper(database):
1484
1482
"""Get peewee exceptions context manager for database
1485
1483
in backward compatible manner.
1486
"""
1487
- if PEEWEE_VERSION <= (2, 8, 5):
1488
- return database.exception_wrapper()
1489
- else:
+ if isinstance(database.exception_wrapper, peewee.ExceptionWrapper):
1490
return database.exception_wrapper
+ else:
+ return database.exception_wrapper()
1491
1492
1493
@asyncio.coroutine
0 commit comments