sqlalchemy.util._concurrency

Class	`_AsyncIoGreenlet`	Undocumented
Class	`AsyncAdaptedLock`	Undocumented
Function	`_util_async_run`	for test suite/ util only
Function	`_util_async_run_coroutine_function`	for test suite/ util only
Function	`await_fallback`	Awaits an async function in a sync method.
Function	`await_only`	Awaits an async function in a sync method.
Function	`get_event_loop`	vendor asyncio.get_event_loop() for python 3.7 and above.
Async Function	`greenlet_spawn`	Runs a sync function `fn` in a new greenlet.
Function	`is_exit_exception`	Undocumented
Variable	`_copy_context`	Undocumented

def _util_async_run(fn, *args, **kwargs):

for test suite/ util only

def _util_async_run_coroutine_function(fn, *args, **kwargs):

for test suite/ util only

def await_fallback(awaitable):

Awaits an async function in a sync method.

The sync method must be inside a greenlet_spawn context. await_ calls cannot be nested.

def await_only(awaitable):

Awaits an async function in a sync method.

The sync method must be inside a greenlet_spawn context. await_ calls cannot be nested.

def get_event_loop():

vendor asyncio.get_event_loop() for python 3.7 and above.

Python 3.10 deprecates get_event_loop() as a standalone.

async def greenlet_spawn(fn, *args, _require_await=False, **kwargs):

Runs a sync function fn in a new greenlet.

The sync function can then use await_ to wait for async functions.

Parameters
fn:`Callable`	The sync callable to call.
*args	Positional arguments to pass to the `fn` callable.
_require_await	Undocumented
**kwargs	Keyword arguments to pass to the `fn` callable.
Returns
`Any`	Undocumented

def is_exit_exception(e):

Undocumented

_copy_context =

Undocumented

sqlalchemy.util._concurrency_py3k