o Hۂ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@s"eZdZd ddZddd d Zd S) FutureKernelfinalize_compilerfuturercCs||_d|_||_dSN)r kernelr)selfr rr`/home/ubuntu/maya3_transcribe/venv/lib/python3.10/site-packages/triton/runtime/_async_compile.py__init__ s zFutureKernel.__init__F ignore_errorsboolcCsN|jdur|jSz|j}Wn ty|rYdSw||||_|Sr)rrresult Exceptionr )rrrrrrrs   zFutureKernel.resultN)r rrr)F)rr)__name__ __module__ __qualname__rrrrrrr s r c@s4eZdZdddddZddZd d Zd d Zd S)AsyncCompileModeF)rexecutorrcCs||_||_g|_i|_dSr)rr raw_futuresfuture_kernels)rrrrrrr"s zAsyncCompileMode.__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__4s  zAsyncCompileMode.__enter__cCs2t|jD] }|j|j|jqtddSr)rrrr"rrr r))rexc_type exc_value tracebackrrrr__exit__:szAsyncCompileMode.__exit__N)rr)rrrrr!r*r.rrrrr s  r) __future__rtypingrrconcurrent.futuresrrr contextvarsrr __annotations__r rrrrrs