summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sqlalchemy')
-rw-r--r--lib/sqlalchemy/pool/base.py10
-rw-r--r--lib/sqlalchemy/pool/impl.py9
-rw-r--r--lib/sqlalchemy/util/langhelpers.py1
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)