diff options
Diffstat (limited to 'lib/sqlalchemy')
| -rw-r--r-- | lib/sqlalchemy/pool/base.py | 10 | ||||
| -rw-r--r-- | lib/sqlalchemy/pool/impl.py | 9 | ||||
| -rw-r--r-- | lib/sqlalchemy/util/langhelpers.py | 1 |
3 files changed, 12 insertions, 8 deletions
diff --git a/lib/sqlalchemy/pool/base.py b/lib/sqlalchemy/pool/base.py index e2ed53800..8a3abb82f 100644 --- a/lib/sqlalchemy/pool/base.py +++ b/lib/sqlalchemy/pool/base.py @@ -53,14 +53,16 @@ class _ConnDialect(object): ) +class _AsyncConnDialect(_ConnDialect): + is_async = True + + class Pool(log.Identified): """Abstract base class for connection pools.""" _dialect = _ConnDialect() - _is_asyncio = False - def __init__( self, creator, @@ -196,6 +198,10 @@ class Pool(log.Identified): for fn, target in events: event.listen(self, target, fn) + @util.hybridproperty + def _is_asyncio(self): + return self._dialect.is_async + @property def _creator(self): return self.__dict__["_creator"] diff --git a/lib/sqlalchemy/pool/impl.py b/lib/sqlalchemy/pool/impl.py index 730293273..99d0c94d2 100644 --- a/lib/sqlalchemy/pool/impl.py +++ b/lib/sqlalchemy/pool/impl.py @@ -13,7 +13,7 @@ import traceback import weakref -from .base import _ConnDialect +from .base import _AsyncConnDialect from .base import _ConnectionFairy from .base import _ConnectionRecord from .base import Pool @@ -34,6 +34,7 @@ class QueuePool(Pool): """ + _is_asyncio = False _queue_class = sqla_queue.Queue def __init__( @@ -222,10 +223,6 @@ class QueuePool(Pool): return self._pool.maxsize - self._pool.qsize() + self._overflow -class _AsyncConnDialect(_ConnDialect): - is_async = True - - class AsyncAdaptedQueuePool(QueuePool): _is_asyncio = True _queue_class = sqla_queue.AsyncAdaptedQueue @@ -307,6 +304,8 @@ class SingletonThreadPool(Pool): """ + _is_asyncio = False + def __init__(self, creator, pool_size=5, **kw): Pool.__init__(self, creator, **kw) self._conn = threading.local() diff --git a/lib/sqlalchemy/util/langhelpers.py b/lib/sqlalchemy/util/langhelpers.py index 1308ee7e0..e506b7529 100644 --- a/lib/sqlalchemy/util/langhelpers.py +++ b/lib/sqlalchemy/util/langhelpers.py @@ -1440,7 +1440,6 @@ class hybridproperty(object): def __get__(self, instance, owner): if instance is None: clsval = self.clslevel(owner) - clsval.__doc__ = self.func.__doc__ return clsval else: return self.func(instance) |
