o ^i@srUddlmZddlmZmZddlmZmZmZddl m Z e dddZ de d <Gd d d Z Gd d d ZdS)) annotations)CallableOptional)Executor as_completedFuture) ContextVarasync_compile_active_modeN)defaultz&ContextVar[Optional[AsyncCompileMode]] active_modec@seZdZd ddZddZd S) FutureKernelfinalize_compilerfuturercCs||_d|_||_dSN)r kernelr)selfr rrX/var/www/html/RAG/RAG_venv/lib/python3.10/site-packages/triton/runtime/_async_compile.py__init__  zFutureKernel.__init__cCs.|jdur|jS|j}||||_|Sr)rrresultr )rrrrrrs   zFutureKernel.resultN)r rrr)__name__ __module__ __qualname__rrrrrrr s  r c@s.eZdZd ddZddZddZd d Zd S) AsyncCompileModeexecutorrcCs||_g|_i|_dSr)r raw_futuresfuture_kernels)rrrrrrrzAsyncCompileMode.__init__cCsN|j|}|dur |S|j|}||_|j|t||}||j|<|Sr)rgetrsubmit_keyrappendr )rkey compile_fn finalize_fnr future_kernelrrrr!s     zAsyncCompileMode.submitcCs"tdur tdt||S)Nz*Another AsyncCompileMode is already active)r r RuntimeErrorset)rrrr __enter__-s  zAsyncCompileMode.__enter__cCs.t|jD] }|j|jqtddSr)rrrr rr r')rexc_type exc_value tracebackrrrr__exit__3szAsyncCompileMode.__exit__N)rr)rrrrrr(r,rrrrrs   r) __future__rtypingrrconcurrent.futuresrrr contextvarsrr __annotations__r rrrrrs