summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/util/concurrency.py
diff options
context:
space:
mode:
authorFederico Caselli <cfederico87@gmail.com>2020-08-16 10:48:57 +0200
committerMike Bayer <mike_mp@zzzcomputing.com>2020-12-30 15:49:09 -0500
commit2581655c545a0cf705e0347e81cd092896d3207c (patch)
tree70a9528216c3de54797b4197978c494ae819d39a /lib/sqlalchemy/util/concurrency.py
parent102b91d8950926f1215dd7c59c5b7f200b5c0f8b (diff)
downloadsqlalchemy-2581655c545a0cf705e0347e81cd092896d3207c.tar.gz
Support testing of async drivers without fallback mode
Change-Id: I4940d184a4dc790782fcddfb9873af3cca844398
Diffstat (limited to 'lib/sqlalchemy/util/concurrency.py')
-rw-r--r--lib/sqlalchemy/util/concurrency.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/sqlalchemy/util/concurrency.py b/lib/sqlalchemy/util/concurrency.py
index f78c0971c..7b4ff6ba4 100644
--- a/lib/sqlalchemy/util/concurrency.py
+++ b/lib/sqlalchemy/util/concurrency.py
@@ -13,6 +13,7 @@ if compat.py3k:
from ._concurrency_py3k import await_fallback
from ._concurrency_py3k import greenlet_spawn
from ._concurrency_py3k import AsyncAdaptedLock
+ from ._concurrency_py3k import _util_async_run # noqa F401
from ._concurrency_py3k import asyncio # noqa F401
if not have_greenlet:
@@ -38,3 +39,6 @@ if not have_greenlet:
def AsyncAdaptedLock(*args, **kw): # noqa F81
_not_implemented()
+
+ def _util_async_run(fn, *arg, **kw): # noqa F81
+ return fn(*arg, **kw)