| Server IP : 84.32.84.121 / Your IP : 216.73.216.254 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/util/ |
Upload File : |
# util/concurrency.py
# Copyright (C) 2005-2024 the SQLAlchemy authors and contributors
# <see AUTHORS file>
#
# This module is part of SQLAlchemy and is released under
# the MIT License: https://www.opensource.org/licenses/mit-license.php
from . import compat
have_greenlet = False
greenlet_error = None
if compat.py3k:
try:
import greenlet # noqa: F401
except ImportError as e:
greenlet_error = str(e)
else:
have_greenlet = True
from ._concurrency_py3k import await_only
from ._concurrency_py3k import await_fallback
from ._concurrency_py3k import greenlet_spawn
from ._concurrency_py3k import is_exit_exception
from ._concurrency_py3k import AsyncAdaptedLock
from ._concurrency_py3k import _util_async_run # noqa: F401
from ._concurrency_py3k import (
_util_async_run_coroutine_function,
) # noqa: F401, E501
from ._concurrency_py3k import asyncio # noqa: F401
# does not need greennlet, just Python 3
from ._compat_py3k import asynccontextmanager # noqa: F401
if not have_greenlet:
asyncio = None # noqa: F811
def _not_implemented():
# this conditional is to prevent pylance from considering
# greenlet_spawn() etc as "no return" and dimming out code below it
if have_greenlet:
return None
if not compat.py3k:
raise ValueError("Cannot use this function in py2.")
else:
raise ValueError(
"the greenlet library is required to use this function."
" %s" % greenlet_error
if greenlet_error
else ""
)
def is_exit_exception(e): # noqa: F811
return not isinstance(e, Exception)
def await_only(thing): # noqa: F811
_not_implemented()
def await_fallback(thing): # noqa: F811
return thing
def greenlet_spawn(fn, *args, **kw): # noqa: F811
_not_implemented()
def AsyncAdaptedLock(*args, **kw): # noqa: F811
_not_implemented()
def _util_async_run(fn, *arg, **kw): # noqa: F811
return fn(*arg, **kw)
def _util_async_run_coroutine_function(fn, *arg, **kw): # noqa: F811
_not_implemented()