NgfdZddlmZddlZejeZdZGddeZ dZ dS)zFA thread pool that logs exceptions raised by tasks executed within it.)futuresNcfd}|S)z:Wraps an arbitrary callable behavior in exception-logging.cj |i|S#t$rtdwxYw)Nz6Unexpected exception from %s executed in logging pool!) Exception_LOGGER exception)argskwargsbehaviors b/var/www/html/ai-engine/env/lib/python3.11/site-packages/grpc/framework/foundation/logging_pool.py _wrappingz_wrap.._wrappings[ 8T,V,, ,      H      s '2)r r s` r _wraprs$ c8eZdZdZdZdZdZdZdZd dZ d S) _LoggingPoolzGAn exception-logging futures.ThreadPoolExecutor-compatible thread pool.c||_dSN) _backing_pool)self backing_pools r __init__z_LoggingPool.__init__)s)rc|Srr)rs r __enter__z_LoggingPool.__enter__,s rc<|jddS)NTwaitrshutdown)rexc_typeexc_valexc_tbs r __exit__z_LoggingPool.__exit__/" ###.....rcH|jjt|g|Ri|Sr)rsubmitr)rfnr r s r r&z_LoggingPool.submit2s.(t!(rDTDDDVDDDrcp|jjt|g|Rd|ddiS)Ntimeout)rmaprget)rfunc iterablesr s r r*z_LoggingPool.map5sM%t!% $KK #   -3ZZ 4-H-H   rTc<|j|dS)Nrr)rrs r rz_LoggingPool.shutdown:r$rN)T) __name__ __module__ __qualname____doc__rrr#r&r*rrrr rr&s|QQ***///EEE   //////rrcDttj|S)a1Creates a thread pool that logs exceptions raised by the tasks within it. Args: max_workers: The maximum number of worker threads to allow the pool. Returns: A futures.ThreadPoolExecutor-compatible thread pool that logs exceptions raised by the tasks executed within it. )rrThreadPoolExecutor) max_workerss r poolr6>s 2;?? @ @@r) r2 concurrentrlogging getLoggerr/rrobjectrr6rrr r;sML ' H % %    /////6///0 A A A A Ar