(phbSrSSKJr SSKr\R"\5rSr"SS\5r Sr g)zFA thread pool that logs exceptions raised by tasks executed within it.)futuresNc^U4SjnU$)z:Wraps an arbitrary callable behavior in exception-logging.c`>T"U0UD6$![a [RST5 ef=f)Nz6Unexpected exception from %s executed in logging pool!) Exception_LOGGER exception)argskwargsbehaviors Y/var/www/html/venv/lib/python3.13/site-packages/grpc/framework/foundation/logging_pool.py _wrapping_wrap.._wrappings@ T,V, ,    H    s "-)r r s` r _wraprs c@\rSrSrSrSrSrSrSrSr S Sjr S r g ) _LoggingPool&zGAn exception-logging futures.ThreadPoolExecutor-compatible thread pool.cXlgN _backing_pool)self backing_pools r __init___LoggingPool.__init__)s)rcU$rr)rs r __enter___LoggingPool.__enter__,s rc6URRSS9 g)NTwaitrshutdown)rexc_typeexc_valexc_tbs r __exit___LoggingPool.__exit__/ ###.rcTURR"[U5/UQ70UD6$r)rsubmitr)rfnr r s r r,_LoggingPool.submit2s'!!((rDTDVDDrctURR"[U5/UQ7SURSS506$)Ntimeout)rmaprget)rfunc iterablesr s r r1_LoggingPool.map5s=!!%% $K # -3ZZ 4-H  rc6URRUS9 g)Nr!r#)rr"s r r$_LoggingPool.shutdown:r*rrN)T) __name__ __module__ __qualname____firstlineno____doc__rrr(r,r1r$__static_attributes__rrr rr&s$Q*/E /rrc@[[R"U55$)aCreates 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 poolrA>s 22;? @@r) r< concurrentrlogging getLoggerr8rrobjectrrArrr rFs8M   H %  /6/0 Ar