JezK
Edit File: asyncio.pyc
� 1��fc @ s� d d l m Z d d l Z d d l m Z d d l m Z d d l m Z e Z d � Z d � Z d � Z d � Z d � Z d S( i����( t wrapsNi ( t configi ( t _util_async_run( t" _util_async_run_coroutine_functionc O s t | | | � S( N( R ( t fnt argst kwargs( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt _run_coroutine_function s c O s# t s | | | � St | | | � S( s Run a function in an asyncio loop unconditionally. This function is used for provisioning features like testing a database connection for server info. Note that for blocking IO database drivers, this means they block the event loop. ( t ENABLE_ASYNCIOR ( R R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt _assume_async$ s c O s= t s | | | � St j r, t | | | � S| | | � Sd S( s� Run a function in an asyncio loop if any current drivers might need it. This function is used for provisioning features that take place outside of a specific database driver being selected, so if the current driver that happens to be used for the provisioning operation is an async driver, it will run in asyncio and not fail. Note that for blocking IO database drivers, this means they block the event loop. N( R R t any_asyncR ( R R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt _maybe_async_provisioning5 s c O sF t s | | | � St j j } | r5 t | | | � S| | | � Sd S( s� Run a function in an asyncio loop if the current selected driver is async. This function is used for test setup/teardown and tests themselves where the current DB driver is known. N( R R t _currentt is_asyncR ( R R R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt _maybe_asyncJ s c sj t j � � rK t � � � f d � � t � � � � � f d � � } n t � � � f d � � } | S( s� Apply the _maybe_async function to an existing function and return as a wrapped callable, supporting generator functions as well. This is currently used for pytest fixtures that support generator use. c s' y t | � SWn t k r" � SXd S( N( t nextt StopIteration( t gen( t _stop( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt call_nextj s c ? sD � | | � } x. t r? t � | � } | � k r7 Pn | Vq Wd S( N( t TrueR ( R R R t value( R R R ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt wrap_fixtureq s c s t � | | � S( N( R ( R R ( R ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyR | s ( t inspectt isgeneratorfunctiont objectR ( R R ( ( R R R sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt _maybe_async_wrapper_ s $ ( t functoolsR R t R t util.concurrencyR R R R R R R R R ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/testing/asyncio.pyt <module> s