o $i@sdZddlZddlZddlmZddlmZzddlZWn ey'dZYnwddZ ddZ d e fd d Z ed d de d e fddZed d ddZdS)zj This file should only be imported from Python 3. It will raise SyntaxError when importing from Python 2. N) lru_cache)env_boolcCstr tddr tStS)zKConstruct a new event loop. Ray will use uvloop if it exists and is enabledRAY_USE_UVLOOPT)uvlooprnew_event_loopasynciorrV/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/_private/async_compat.pyget_new_event_loopsr cCs tr tddr tdS dS)zSInstalls uvloop as event-loop implementation for asyncio (if available and enabled)rTN)rrinstallrrrr try_install_uvloops r returncCst|p t|S)zBReturn True if the function is an async or async generator method.)inspectiscoroutinefunctionisasyncgenfunctionfuncrrr is_async_func!sri)maxsizeclscCsttj|tddkS)z/Return True if the class has any async methods.) predicater)lenr getmembersr)rrrr has_async_methods&srcstrSfdd}|S)z-Wrap a blocking function in an async functioncs|i|S)Nr)argskwargsrrr wrapper3szsync_to_async..wrapper)r)rrrrr sync_to_async,s r)__doc__rr functoolsrray._private.ray_constantsrr ImportErrorr r boolrobjectrrrrrr s"