diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-09-14 08:04:09 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-09-14 08:04:09 -0400 |
| commit | 4d17fe4063adef50c1d529993e0b047f503940e2 (patch) | |
| tree | 20b53461c593e71297fa034ccdaaea629c461728 /lib/sqlalchemy/pool/base.py | |
| parent | 056c929e15c735059b2f17f9ae5391d3ad244907 (diff) | |
| download | sqlalchemy-4d17fe4063adef50c1d529993e0b047f503940e2.tar.gz | |
Adapt event exec_once_mutex to asyncio
The pool makes use of a threading.Lock() for the
"first_connect" event. if the pool is async make sure this
is a greenlet-adapted asyncio lock.
Fixes: #5581
Change-Id: If52415839c7ed82135465f1fe93b95d86c305820
Diffstat (limited to 'lib/sqlalchemy/pool/base.py')
| -rw-r--r-- | lib/sqlalchemy/pool/base.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/sqlalchemy/pool/base.py b/lib/sqlalchemy/pool/base.py index f20b63cf5..87383fef7 100644 --- a/lib/sqlalchemy/pool/base.py +++ b/lib/sqlalchemy/pool/base.py @@ -59,6 +59,8 @@ class Pool(log.Identified): _dialect = _ConnDialect() + _is_asyncio = False + def __init__( self, creator, |