7iUddlmZddlmZmZddlmZmZmZddl m Z e ddZ de d <Gd d Z Gd d Zy)) annotations)CallableOptional)Executor as_completedFuture) ContextVarasync_compile_active_modeN)defaultz&ContextVar[Optional[AsyncCompileMode]] active_modeceZdZddZdZy) FutureKernelc.||_d|_||_yN)finalize_compilekernelfuture)selfrrs Z/home/rose/Desktop/poly/venv/lib/python3.12/site-packages/triton/runtime/_async_compile.py__init__zFutureKernel.__init__ s 0  c|j |jS|jj}|j|||_|Sr)rrresultr)rrs rrzFutureKernel.resultsB ;; ";; ##% f%  rN)rrrr)__name__ __module__ __qualname__rrrrrr s  rrc&eZdZddZdZdZdZy)AsyncCompileModec.||_g|_i|_yr)executor raw_futuresfuture_kernels)rr!s rrzAsyncCompileMode.__init__s   rc|jj|}||S|jj|}||_|j j |t||}||j|<|Sr)r#getr!submit_keyr"appendr)rkey compile_fn finalize_fnr future_kernels rr&zAsyncCompileMode.submit!st$$((-  M%%j1  '$[&9 #0C rcntj tdtj||S)Nz*Another AsyncCompileMode is already active)r r% RuntimeErrorset)rs r __enter__zAsyncCompileMode.__enter__-s, ??  (KL L rct|jD])}|j|jj +t j dyr)rr"r#r'rr r/)rexc_type exc_value tracebackrs r__exit__zAsyncCompileMode.__exit__3s>"4#3#34F    , 3 3 55rN)r!r)rrrrr&r0r5rrrrrs!  rr) __future__rtypingrrconcurrent.futuresrrr contextvarsr r __annotations__rrrrrr;s<"%=="6@A\fj6k 3k"r