o V h@ @sUddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z Gdddej ZejZeeZdd d%ddZejdedZejdddZd&ddZd'd(ddZejrided<d ed!<nd"d#Zgd$ZdS))) annotationsN)MappingSequence)partial)StrPathc@seZdZddd d d ZdS) _LoggerNoriginmessagestrr tuple[str, ...] | NonereturnNonecCsdSN)selfr r rr^/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/build/_ctx.py__call__sz_Logger.__call__r r r r rr)__name__ __module__ __qualname__rrrrrrsrr r r r r rrcCs"|durtjtj|dddSdS)N) stacklevel)_default_loggerlogloggingINFO)r r rrr _log_defaultsrLOGGER)default VERBOSITYerrorsubprocess.CalledProcessErrorcCsZt}|t|jdddD]}t||}|r*|t|tr#|n|d|fdqdS)N subprocesscmdr stdoutstderrr&) r getr& list2cmdliner'getattr isinstancebytesdecode)r#r stream_namestreamrrrlog_subprocess_errors "r3r'Sequence[StrPath]envMapping[str, str] | Nonec s.t}|rxddl}tdfdd |jjd d Rtj|d |tjtjd -t |dd|j fdddD }|rOt |j Wdn1sYwYWddSWddS1sqwYdSz tj |dd|dWdStj y}zt|d}~ww)Nrr1r r2typing.IO[str]rrcs|D] }|d|fdqdS)Nr&r r)r1r2line)rrr log_stream2sz"run_subprocess..log_streamr) max_workerszutf-8)encodingr5r)r*r%r c s$g|]}t|t|qSr)submitrr-).0n)executorr9processrr >s$z"run_subprocess..r(T)capture_outputcheckr5)r1r r2r7rr)r"r+concurrent.futuresr futuresThreadPoolExecutorr&PopenPIPEr,waitCalledProcessErrorargsrunr3)r'r5 verbosity concurrentcoder#r)r?rr9r@rrun_subprocess*s2PrPrboolrMcCs(|dkrtS|dkrtSt|)NrrM)r r+r"AttributeError)namerrr __getattr__Ss rT)r3rrPr rMr"r)r#r$rrr)r'r4r5r6rr) __future__r contextvarsrr&typingcollections.abcrr functoolsr_typesrProtocolr__spec__parent _package_name getLoggerrr ContextVarr r"r3rP TYPE_CHECKING__annotations__rT__all__rrrrs*     #